Kafka Validation

This section describes ways you can use Kafka tools for data capture for analysis.

kafka-topics --create --zookeeper datacouch.training.io:2181/kafka --replication-factor 1 --partitions 1 --topic test

Let's create a topic named "test" with a single partition and only one replica:

kafka-topics --list --zookeeper datacouch.training.io:2181/kafka

kafka-console-producer

Read data from standard output and write it to a Kafka topic. For example:

kafka-console-producer --broker-list datacouch.training.io:9092 --topic test

kafka-console-consumer

Kafka also has a command line consumer that will dump out messages to standard output.

kafka-console-consumer --bootstrap-server datacouch.training.io:9092 --topic test --from-beginning