Kafka 提供了命令行工具 kafka-console-producer.sh(Unix/Linux)和 kafka-console-producer.bat(Windows),用于在 Kafka 主題中創(chuàng)建消息的生產(chǎn)者。下面是使用 Kafka 生產(chǎn)者命令的示例:
1.發(fā)送消息到默認(rèn)的 Kafka 服務(wù)器(localhost:9092)和主題(my_topic):
kafka-console-producer.sh --broker-list localhost:9092 --topic my_topic
2.發(fā)送消息到指定的 Kafka 服務(wù)器和主題:
kafka-console-producer.sh --broker-list kafka_server1:9092,kafka_server2:9092 --topic my_topic
3.發(fā)送消息并指定消息鍵(key):
kafka-console-producer.sh --broker-list localhost:9092 --topic my_topic --property "parse.key=true" --property "key.separator=:"
然后,在命令行中輸入消息鍵和消息內(nèi)容,使用鍵值分隔符(在上面的示例中是冒號(hào))分隔鍵和值。
4.發(fā)送消息到指定分區(qū):
kafka-console-producer.sh --broker-list localhost:9092 --topic my_topic --property "parse.key=true" --property "key.separator=:" --property "partition=1"
在這個(gè)示例中,消息將被發(fā)送到主題 my_topic 的分區(qū) 1。
這些命令示例僅供參考,實(shí)際使用時(shí),請(qǐng)根據(jù)你的 Kafka 集群配置和需求進(jìn)行相應(yīng)的調(diào)整。可以通過運(yùn)行 kafka-console-producer.sh 或 kafka-console-producer.bat 命令來查看可用選項(xiàng)和參數(shù)的完整列表以及命令的用法說明。