Kafka控制台生产者持续发送消息

要实现Kafka控制台生产者持续发送消息，可以使用脚本来不断发送消息。

以下是一个示例脚本，使用Kafka提供的命令行工具kafka-console-producer.sh来发送消息：

#!/bin/bash

topic="your_topic_name"
broker="your_broker_address"

while true; do
    echo "Enter message: "
    read message

    # 使用kafka-console-producer.sh发送消息
    echo "$message" | kafka-console-producer.sh --broker-list $broker --topic $topic
done

请注意将"your_topic_name"和"your_broker_address"替换为实际的主题名称和Kafka代理地址。

这个脚本会进入一个无限循环，在每次循环中，它会要求用户输入消息，并使用kafka-console-producer.sh发送消息到指定的主题。用户可以通过键盘输入任意数量的消息，然后按Ctrl+C来停止发送。

要使用此脚本，将其保存为一个文件（例如script.sh）并为文件添加执行权限：

chmod +x script.sh

然后通过运行脚本来开始发送消息：

./script.sh

脚本将提示用户输入消息，并将其发送到Kafka主题中。