THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
HTTP/1.1 200 OK Content-Type: application/vnd.kafka.binary.v1+json [ { "key": "a2V5", "value": "dmFsdWU=", "partition": 1, "offset": 1, }, { "key": "a2V5", "value": "dmFsdWU=", "partition": 1, "offset": 2, } ] |
GET /topics/:topic/messages?group=<group>
Description : consumes a message from the specified topic on behalf of the specified consumer group
Parameters:
topic (String) - topic name
group (String) - consumer group id
Response:
JSON Object contains response objects
Status Codes:
404 Not Found
Error Code 40401 - topic Not Found
500 Internal Server Error
Error Code 50001 - Kafka Error
Example binary request:
GET /topics/test/messages?group=testgroup HTTP/1.1 Accept: application/vnd.kafka.binary.v1+json |
Example response:
HTTP/1.1 200 OK Content-Type: application/vnd.kafka.binary.v1+json [ { "key": "a2V5", "value": "dmFsdWU=", "partition": 1, "offset": 1, }, { "key": "a2V5", "value": "dmFsdWU=", "partition": 1, "offset": 2, } ] |
POST /topics/:group/offsets
Description : Commit offsets for the consumer instance associated with group.
Parameters:
group (String) - consumer group id
Response:
JSON Object contains response objects
Status Codes:
404 Not Found
Error Code 40401 - group Not Found
500 Internal Server Error
Error Code 50001 - Kafka Error
Example request:
POST /topics/testgroup/offsets HTTP/1.1 Accept: application/vnd.kafka.v1+json |
Example response:
HTTP/1.1 200 OK Content-Type: application/vnd.kafka.v1+json [ { "topic": "topic", "partition": 1, "committed": 1 }, { "topic": "topic", "partition": 2, "committed": 2 }, ] |
Compatibility, Deprecation, and Migration Plan
...