想通过bash脚本发送一些消息.
bin/zookeeper-server-start.sh config/zookeeper.properties > zookeeper.log 2>&1 &
sleep 2
bin/kafka-server-start.sh config/server.properties > server.log 2>&1 &
sleep 2
#Create topic
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic $1
sleep 2
#Get topics list
echo "kafka has next topics:"
bin/kafka-topics.sh --list --zookeeper localhost:2181
#send message
echo "will send messages:"
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic $1 "test 1"
卡夫卡开局不错.我可以通过制作人控制台发送消息
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic $1 "test 1"
但我不能发送消息到bash脚本.如何通过bash脚本发送它？
谢谢.