【发布时间】:2021-05-24 16:52:16
【问题描述】:
如果我想使用来自 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) 时,我该如何阻止它?
谢谢。
【问题讨论】:
标签: apache-kafka confluent-platform