kafka-rest
kafka-rest copied to clipboard
confluentinc
Confluent REST Proxy for Kafka
When create topics without payload, a general server errors will return currently: ``` curl -X POST http://localhost:9391/v3/clusters/kZ7pDeiQSS-9eRtOXlWSMQ/topics -H "Authorization: Basic ABC" returns a {"error_code":500,"message":"Internal Server Error"}% ``` But this should...
rest-utils-parent:[7.3.0, 7.3.1-0] is neither available in https://packages.confluent.io/maven/io/confluent/kafka-rest-parent nor in any sources.
Ref. https://docs.confluent.io/platform/current/kafka-rest/api.html#records-v3 From above document show some example: `{ "key": { "subject_name_strategy": "TOPIC_NAME", "schema_id": 1, "data": 1000 }, "value": { "schema_version": 1, "data": { "foo": "bar" } } }` foo...
version: 4.1.1 ```shell curl -X GET -H "Accept: application/vnd.kafka.avro.v2+json" \ http://localhost:8082/consumers/testgroup2/instances/ym_test/records ``` ```shell [2018-06-28 20:29:15,439] INFO 0:0:0:0:0:0:0:1 - - [28/六月/2018:20:28:04 +0800] "GET /consumers/testgroup2/instances/ym_test/records HTTP/1.1" 500 187 70513 (io.confluent.rest-utils.requests:77) [2018-06-28 20:29:15,446]...
Hi, just replaced the deprecated method with the new one. Best regards :) Originally we were working on: #432
This PR adds code to reflect Kafka rate limiting back to the http client. While the produce api response from Kafka does indicate that the client is being throttled to...
I noticed that if I send a message using the rest proxy v3 API, I can't consume it using the v2 API. I always get an empty array no matter...
Have configured confluentinc/cp-kafka-rest:5.5.9-1-ubi8 in eks and all is working. however when enabling BASIC auth we keep getting back 403 errors. ``` "servlet":"default", "message":"!role", "url":"/topics", "status":"403" ``` Env vars ``` -...
The following is the "on the wire" interaction between our REST client and the Kafka REST Proxy. A summary of the operations performed is: 1. Start the various docker images...
