【问题标题】:Get Kafka messages between two datetime from a topic?从一个主题获取两个日期时间之间的 Kafka 消息?
【发布时间】: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


【解决方案1】:

您可以通过kafkacat 做到这一点

kafkacat -b mybroker -C -t mytopic -o s@1568276612443 -o e@1568276617901

其中两个时间戳指定为milliseconds since the Unix epoch

【讨论】:

  • 嗨罗宾,谢谢你,但我的服务器上没有 kafkacat,很遗憾也无法下载它,你能帮助一些其他与 confluent 平台一起提供的实用程序吗?
  • 在windows中有kafkacat的等效命令吗?
  • @Pra_A 你可以在 Windows 的 Docker 下运行 Kafkacat
猜你喜欢
  • 2017-11-26
  • 2019-06-22
  • 2012-03-24
  • 1970-01-01
  • 1970-01-01
  • 2013-09-08
  • 1970-01-01
  • 1970-01-01
  • 2018-01-11
相关资源
最近更新 更多