REST Proxy V2 examples

gistfile1.txt

Create JSON consumer:
curl -X POST -H "Content-Type: application/vnd.kafka.v2+json" --data '{"name": "my_consumer_instance", "format": "JSON", "auto.offset.reset": "earliest"}' http://localhost:8082/consumers/my_json_consumer
{"instance_id":"my_consumer_instance", "base_uri":"http://localhost:8082/consumers/my_json_consumer/instances/my_consumer_instance"}

Subscribe consumer to a topic:
curl -X POST -H "Content-Type: application/vnd.kafka.v2+json" --data '{"topics":["jsontest"]}' http://localhost:8082/consumers/my_json_consumer/instances/my_consumer_instance/subscription

Consume:
curl -X GET -H "Accept: application/vnd.kafka.json.v2+json" http://localhost:8082/consumers/my_json_consumer/instances/my_consumer_instance/records

curl -X GET -H "Accept: application/vnd.kafka.json.v2+json" http://localhost:8082/consumers/my_json_consumer/instances/my_consumer_instance/topics/jsontest

Delete:
curl -X DELETE http://localhost:8082/consumers/my_json_consumer/instances/