背景:
基于Kafka实现了一个公共延迟队列, 类似于rocketmq的固定间隔的公共延迟队列。
实现办法是,在kafka创建若干间隔的Topic,比如2s,3s,1m,1h,1d 若干维度,
对每个维度的Topic,都有一个消费者处理,消费者的逻辑是,如果消费到的message
的触发时间小于当前时间,则将这个message转发到用户自己的Topic中。如果不满足
则sleep到满足的时间。
问题
对于1h或者1d这样的consumer,有可能两次poll的时间间隔达到1h或者1d,这样再次
poll时报错。 为了解决这个问题,我们增大了max-poll-interval-ms 为1d。
请问,把这个配置调成1d的话,会有什么影响?
等到时间过长 导致的此问题。没什么的。
不过不建议kafka做延迟队列,很被动。也失去了性能优势。
你的答案