shell读取文本数据kafka生产数据（shell脚本）

1，数据 ：vi /home/test/1.txt

 2：脚本：vi flink_kafka.sh

#!/bin/bash
cat /home/test/1.txt | while read line
do
        dt=`date +"%Y-%m-%d %H:%M:%S" -d "0 days"`
        echo $line-$dt | /opt/cloudera/parcels/CDH/bin/kafka-console-producer --broker-list
自己的ip:9092 --topic kafka主题
done