开发和学习时需要造一些 kafka 消息，于是写了段脚本实现，在这里记录备忘，后面会常用到

#!/bin/sh
#响应Ctrl+C中断trap 'onCtrlC' INTfunction onCtrlC () {    echo 'Ctrl+C is captured'    exit 1}
#kafka所在目录kafkaPath=/Users/zhaoqin/temp/202003/07/kafka_2.11-2.0.1#brokerbrokerlist=192.168.50.135:31090,192.168.50.135:31091,192.168.50.135:31092#kafka的topictopic=test001#消息总数totalNum=10000#一次批量发送的消息数batchNum=100#该标志为true，表示文件中的第一条记录firstLineFlag='true'
for ((i=1; i<=${totalNum}; i ++))  do      #消息内容，请按照实际需要自行调整    messageContent=batchmessage-${i}-`date "+%Y-%m-%d %H:%M:%S"`
    #如果是每个批次的第一条，就要将之前的内容全部覆盖，如果不是第一条就追加到尾部    if [ 'true' == ${firstLineFlag} ] ; then      echo ${messageContent} > batchMessage.txt
      #将标志设置为false，这样下次写入的时候就不会清理已有内容了      firstLineFlag='false'    else      echo ${messageContent} >> batchMessage.txt    fi
    #取余数    modVal=$(( ${i} % ${batchNum} ))
    #如果达到一个批次，就发送一次消息    if [ ${modVal} = 0 ] ; then      #在控制台显示进度      echo “${i} of ${totalNum} sent”
      #批量发送消息，并且将控制台返回的提示符重定向到/dev/null      cat batchMessage.txt | ${kafkaPath}/bin/kafka-console-producer.sh --broker-list ${brokerlist} --sync --topic ${topic} | > /dev/null
      #将标志设置为true，这样下次写入batchMessage.txt时，会将文件中的内容先清除掉      firstLineFlag='true'    fidone

(base) zhaoqindeMBP:07 zhaoqin$ ./sendmessage5.sh“100 of 10000 sent”“200 of 10000 sent”“300 of 10000 sent”“400 of 10000 sent”“500 of 10000 sent”“600 of 10000 sent”“700 of 10000 sent”“800 of 10000 sent”...

./kafka-console-consumer.sh \--bootstrap-server 192.168.50.135:31090 \--topic test001 \--from-beginning