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 命令來查看可用選項和參數的完整列表以及命令的用法說明。