如何配置kafka消费者只在给定的时间范围内侦听消息

yhived7q  于 2021-06-06  发布在  Kafka
关注(0)|答案(1)|浏览(421)

我想我的Kafka消费者听Kafka服务器只从上午8点到晚上8点。它不应该监听超出该时间范围的请求。这种配置是否可行。如果是的话,怎么做。
我用java开发了kafka消费程序。
谢谢您。

wj8zmpe1

wj8zmpe11#

Kafka不关心你的消费者,所以没有配置。
或者让你的消费者完全停止在你的时间范围之外消费(想想cron job,或者如果超出了时间范围就不要投票),或者消费但不处理,这会推进补偿。
第一种选择是在早上8点“继续”工作,第二种选择是忽略你时间范围之外的所有事情。如果你拥有消费者,它应该很容易实现。

相关问题