主页 / unix / 问题 / 778676
Accepted
Aleksey
Asked: 2024-06-20 21:30:10 +0800 CST

如何防止Kafka警告消息循环

  • 772

Apache Kafka运行 CLI 命令时--list会引发警告

WARN [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.

并使其循环地不会被Ctrl + C按下。

如何防止循环并使用稍后可以使用的适当退出代码一次性发出消息？

linux

1 个回答

  1. Best Answer

    对于不特定于 kafka 的通用解决方案，您可以使用timeout。

    例如

    timeout 10s kafkasomething --list

    124如果超时，它将退出——但它不会自己告诉你更多信息。你可以捕获输出并处理它，以帮助你确定失败的原因。

    例如

    tempfile="$(mktemp)"
timeout 10s kafkasomething --list | tee "${tempfile:?}"
result=$?
case $result in
  (0)
    echo 'Command OK'
    ;;
  (124)
    grep -F 'Broker may not be available' "${tempfile}" && echo 'Broker not available'
    grep -F 'foo' "${tempfile}" && echo 'Found a foo'
    ;;
  (*)
    echo "Unhandled result: $result"
  ;;
esac

rm "${tempfile}"
    • 1

相关问题