Apache Kafka

Producer Commands

Kafka producers send messages to topics. Learn to use the console producer for testing and understand producer configurations.

4 commands

Pro Tips

Use message keys to ensure related messages go to the same partition.

Use acks=all for critical data to ensure replication before acknowledgment.

$ kafka-console-producer.sh --topic my-topic --bootstrap-server localhost:9092

Start interactive producer.

$ kafka-console-producer.sh --topic my-topic --bootstrap-server localhost:9092 --property parse.key=true --property key.separator=:

Produce key:value messages.

$ kafka-console-producer.sh --topic my-topic --bootstrap-server localhost:9092 < messages.txt

Send messages from file.

$ kafka-console-producer.sh --topic my-topic --bootstrap-server localhost:9092 --producer-property acks=all

Produce with all replicas acknowledgment.