Kafka 提供了命令行工具 kafka-console-producer.sh(Unix/Linux)和 kafka-console-producer.bat(Windows),用于在 Kafka 主题中创建消息的生产者。下面是使用 Kafka 生产者命令的示例:
1.发送消息到默认的 Kafka 服务器(localhost:9092)和主题(my_topic):
kafka-console-producer.sh --broker-list localhost:9092 --topic my_topic
2.发送消息到指定的 Kafka 服务器和主题:
kafka-console-producer.sh --broker-list kafka_server1:9092,kafka_server2:9092 --topic my_topic
3.发送消息并指定消息键(key):
kafka-console-producer.sh --broker-list localhost:9092 --topic my_topic --property "parse.key=true" --property "key.separator=:"
然后,在命令行中输入消息键和消息内容,使用键值分隔符(在上面的示例中是冒号)分隔键和值。
4.发送消息到指定分区:
kafka-console-producer.sh --broker-list localhost:9092 --topic my_topic --property "parse.key=true" --property "key.separator=:" --property "partition=1"
在这个示例中,消息将被发送到主题 my_topic 的分区 1。
这些命令示例仅供参考,实际使用时,请根据你的 Kafka 集群配置和需求进行相应的调整。可以通过运行 kafka-console-producer.sh 或 kafka-console-producer.bat 命令来查看可用选项和参数的完整列表以及命令的用法说明。