kafka-rest
kafka-rest copied to clipboard
confluentinc
Confluent REST Proxy for Kafka
Hi is there any way to delete the consumer group which is no longer needed. I know we can delete it through kafka broker or it will delete itself after...
`ApplicationServer.wrapWithGzipHandler()` does not call `GzipHandler.setInflateBufferSize()` causing Kafka REST to fail to process requests with compressed content. # Relevant code - https://github.com/confluentinc/rest-utils/blob/b275c66b9b3b80a5c431e0648b8d5c5ff9e61f11/core/src/main/java/io/confluent/rest/ApplicationServer.java#L466-L474 - https://github.com/eclipse/jetty.project/blob/c50bed4e65d5cead6f19ffbbf1eb3f27c4cef196/jetty-server/src/main/java/org/eclipse/jetty/server/handler/gzip/GzipHandler.java#L617-L632 # Steps to reproduce 1. Install Confluent...
Hello, I would like to know if there is any incompatibility to use the REST proxy from confluent 5.5.3 with confluent 5.2.2 brokers.
Currently, we use an AWS ALB to route incoming traffic to an EC2 instance, which in turn adds the data to our Kafka brokers. Can we replace this EC2 with...
Currently we can see the option to read messages only after creating consumer instance and subscribe it to topic. But What if I already a kafka cluster in which there...
Hi is there any end point using which we can use to get the instance id of the consumers within a consumer groups. Currently all consumers endpoint requires that. Also...
I can't access api use code below: ` String json = "{\"partitions\":[{\"topic\":\"rest-proxy-test\",\"partition\":0}]}"; String baseUrl = "http://slave2.anywhere.com:8082/"; String url = "consumers/my_json_consumer/instances/office_consumer_instance/offsets"; URLConnection connection = new URL(baseUrl + url).openConnection(); Charset charset =...
in our test case, we try to authenticate a wrong user with producer API, then broker throw SaslAuthenticationException, the main thread (qtp1643691748-32) catch this exception, response 401 to client, which...
For those issues: https://github.com/confluentinc/kafka-rest/issues/698 https://github.com/confluentinc/kafka-rest/issues/523 Example: ` "headers": [ {"key1": "value1"}, {"key2": "value2"}, {"key1": "value3"} ] ` By this https://github.com/confluentinc/kafka-rest/issues/523#issuecomment-528032386
