Joe*_*ang 8 apache-kafka kafka-consumer-api
我们正面临着卡夫卡的问题.
基本上我们只有一个分区的主题,而消费组中只有一个消费者.
消费者已经停了一个月.在此期间,制作人仍然会向主题发送消息.
然而,在第一次,我们再次启动消费者,消费者无法消费消息我认为先前提交的偏移已经丢失,因此消费者不知道在唤醒时找到起点.
所以我们必须再次停止并启动消费者,然后现在消费者可以获取新消息,但是之前发送的所有消息都被消耗掉了.
我的假设是,抵消是如何被破坏的？保留期是否适用于kafka内部主题[_offsets],是否已删除最后提交的偏移量？
请指教？
可以使用以下方法在kafka代理中配置保留值：
offsets.retention.minutes
默认值为24小时。请参阅： 卡夫卡消费群体抵销保留
| 归档时间： |
|
| 查看次数： |
13409 次 |
| 最近记录： |