The Confluent REST Proxy provides a “RESTful interface” on top of Kafka, allowing you to produce and consume messages using simple HTTP requests. In this lab, you will have the opportunity to interact with the REST proxy by consuming some existing messages. This will give you some hands-on experience with the requests necessary for consuming Kafka data using REST.
Learning Objectives
Successfully complete this lab by achieving the following learning objectives:
- Provide the Number of Apples Sold in the Last Week
Create a new consumer and
consumer_instance:curl -X POST -H "Content-Type: application/vnd.kafka.v2+json" --data '{"name": "sales_consumer_instance", "format": "json", "auto.offset.reset": "earliest"}' http://localhost:8082/consumers/sales_json_consumerSubscribe the consumer to the
weekly_salestopic:curl -X POST -H "Content-Type: application/vnd.kafka.v2+json" --data '{"topics":["weekly_sales"]}' http://localhost:8082/consumers/sales_json_consumer/instances/sales_consumer_instance/subscriptionConsume the messages:
curl -X GET -H "Accept: application/vnd.kafka.json.v2+json" http://localhost:8082/consumers/sales_json_consumer/instances/sales_consumer_instance/recordsLocate the latest record with a key of
applesand copy its value.Edit the output file:
vi /home/cloud_user/output/apple_sales.txtPaste in the value from the latest
applesrecord and save the file.
- Provide the Current Quarterly Balance for Product Purchases
Create a new consumer and
consumer_instance:curl -X POST -H "Content-Type: application/vnd.kafka.v2+json" --data '{"name": "balance_consumer_instance", "format": "json", "auto.offset.reset": "earliest"}' http://localhost:8082/consumers/balance_json_consumerSubscribe the consumer to the
quarterly_purchasestopic:curl -X POST -H "Content-Type: application/vnd.kafka.v2+json" --data '{"topics":["quarterly_purchases"]}' http://localhost:8082/consumers/balance_json_consumer/instances/balance_consumer_instance/subscriptionConsume the messages:
curl -X GET -H "Accept: application/vnd.kafka.json.v2+json" http://localhost:8082/consumers/balance_json_consumer/instances/balance_consumer_instance/recordsLocate the latest record and copy its value.
Edit the output file:
vi /home/cloud_user/output/quarterly_balance.txtPaste in the value from the latest record and save the file.
