kafka-topics --bootstrap-server broker:9092 --topic TOPIC_NAME
kafka-console-consume --bootstrap-server broker:9092 --topic TOPIC_NAME
add --from-begginning
if you want all messages.
kafka-console-producer --bootstrap-server broker:9092 --topic TOPIC_NAME
and then write your messages.
http POST http://localhost:8083/connectors @datagen-orders-config.json
http http://localhost:8083/connectors/datagen-orders/status -b
http DELETE http://localhost:8083/connectors/datagen-orders -b
- Add a schema registry and create a schema for each table;
- Add KSQL capability and stream process some data to a new topic;
- Create a Kafka Stream data processing job;
- Add Schemma evolution;