kafka-console-consumer --topic test-topic --from-beginning --consumer.config=consumer.properties --bootstrap-server=localhost:9092
kafka-console-producer --producer.config=producer.properties --topic test-topic
Name | Name | Last commit date | ||
---|---|---|---|---|
parent directory.. | ||||
kafka-console-consumer --topic test-topic --from-beginning --consumer.config=consumer.properties --bootstrap-server=localhost:9092
kafka-console-producer --producer.config=producer.properties --topic test-topic