shell脚本向Kafka里生产数据

    技术2024-03-28  104

    开始写脚本的时候,不知道如何把数据不用手动写入Kafka,只能在屏幕上单个输入。

    #!/bin/bash kafkaPath=/****自己kafka的路径****/ 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
    Processed: 0.021, SQL: 9