我正在使用kafka，并且想监视主题。基本上，我将几个主题输出到stdout并归档以供以后查看。对于单主题监视，我想出了以下命令：
${KAFKA_HOME}/bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic mytopic | \
while IFS= read -r line; do
printf '[%s | %20s] %s\n' "$(date '+%Y-%m-%d %H:%M:%S')" "mytopic" "${line}";
done | tee -a kafka.out
但是，有很多主题需要消耗，因此我正在尝试做类似的事情
consumer=${KAFKA_HOME}/bin/kafka-console-consumer.sh
mapfile -t topics < <(${KAFKA_HOME}/bin/kafka-topics.sh --zookeeper localhost:2181 --list)
for i in ${topics[@]}; do
xterm -T ${i} -e "my_command" &
done
tail -F kafka.out
my_command上面的命令在哪里。它不起作用。我怀疑自己搞砸了引号，但不幸的是我无法弄清楚如何正确应用引号
如果要逐字存储一些文本，使用以下语法通常会更容易：
mycommand=$(cat << 'EOF'
"${KAFKA_HOME}/bin/kafka-console-consumer.sh" --zookeeper localhost:2181 --topic "$TOPIC" |
while IFS= read -r line; do
printf '[%s | %20s] %s\n' "$(date '+%Y-%m-%d %H:%M:%S')" "$TOPIC" "${line}";
done | tee -a kafka.out
EOF
)
在ksh93，bash或者zsh，你也可以把它：
mycommand=$(<<'EOF'
....
EOF
在ksh93优化了猫和铲叉的EXEC，同时与bash只有EXEC（在zsh，这都没有区别）。
在mksh：
mycommand=<<'EOF'
...
EOF
进而：
export TOPIC KAFKA_HOME
for TOPIC in "${topics[@]}"; do
xterm -T "$TOPIC" -e "$mycommand" &
done
在这里，我会使用ts到时间戳的输入（或做它gawk或者perl如果ts不可用），而不是说非常低效while read循环。
ts '[%F %T | mytopic]'
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句