问题描述
我需要编写shell脚本，以使用“ bin / kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost：9092阅读特定主题的kafka消息。 ”仅持续一定的时间，例如10秒。使用选项--超时10s 并没有帮助，因为如果持续出现有关特定主题的消息，则该过程不会在10s之后停止。请建议如何做。
解决方法
您可以使用外部脚本，该脚本将在需要的时间后将其杀死。 kafka-console-consumer --timeot-ms标志用于空闲时间，不是您要的时间。
或者，如果知道消息速率/秒并评估在10秒钟内将收到多少消息，则可以在--max-messages之后停止。