开始写脚本的时候,不知道如何把数据不用手动写入Kafka,只能在屏幕上单个输入。
#
!/bin
/bash
kafkaPath
=
zkaddress
=127.0.0.1:2181
kafkaaddress
=127.0.0.1:9092
topic_key
="YM"
$kafkaPath
/bin
/kafka
-topics
.sh
--create
--zookeeper $
{zkaddress
} --replication
-factor
1 --partitions
1 --topic $
{topic_key
}
#$kafkaPath
/bin
/kafka
-console
-producer
.sh
--broker
-list localhost
:9092 --topic topic_key
for((i
=0;i
<1;i
++))
do
# json1
echo
"JSON" | $kafkaPath
/bin
/kafka
-console
-producer
.sh
--broker
-list localhost
:9092 --topic $
{topic_key
}
done
转载请注明原文地址:https://ipadbbs.8miu.com/read-48476.html