如果我想使用来自 Kafka 主题的两个特定日期(例如 2 月 20 日 00:00:00 和 2 月 22 日 00:00:00)之间的消息，应使用什么命令？
我所知道的是，有消费者组命令，我们可以在其中给出“--to-datetime”、“--by-duration”等。
bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092
--group test-group --reset-offsets --all-topics --to-datetime 2021-02-20T00:00:00.000
但是当该消费者组到达特定日期时间 (2021-02-22T00:00:00.000) 时，如何停止该消费者组？
谢谢。
最佳答案
您可以使用kafkacat来做到这一点
kafkacat -b mybroker -C -t mytopic -o s@1568276612443 -o e@1568276617901
其中两个时间戳被指定为 milliseconds since the Unix epoch
关于apache-kafka - 从主题的两个日期时间之间获取 Kafka 消息？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/66315829/