如何编写一个 bash 命令来打开一个 kafka 生产者并立即跟随主题创建？

Question

运行以下命令序列的最佳方法是什么

kafka-console-producer --topic discounts --broker-list localhost:9092 --property parse.key=true --property key.separator=,
profile1,{"profile":"profile1","amount":0.5 }
profile2,{"profile":"profile2","amount":0.25 }
profile3,{"profile":"profile3","amount":0.15 }
exit
kafka-console-producer --topic discount-profiles-by-user --broker-list localhost:9092 --property parse.key=true --property key.separator=,
Daniel,profile1
Riccardo,profile2
exit
...

我正在尝试为主题批量创建 kafka 消息而无需逐行输入

Answer 1

without typing line-by-line

使用您要上传的数据创建文件

然后使用bash重定向

kafka-console-producer \
 --topic discounts \
 --broker-list localhost:9092 \
 --property parse.key=true --property key.separator=, < data.csv

如果按主题名称命名文件，则可以在每个文件上编写一个 for 循环，并使用该文件名作为主题名称

如何编写一个 bash 命令来打开一个 kafka 生产者并立即跟随主题创建？

How to write a bash command to open up a kafka producer and immediately follow with topic to create?

bash

apache-kafka