返回到文章

采纳

编辑于

kafka用的别人的集群,我这边消费者连上去之后,消费不了之前已经存在的消息,我消费者在线的时候才能消费当前新的消息

kafka

就是只有消费者在线才能消费消息,消费不了历史消息,我看了下文档,怀疑是我消费者连上去之后找不到消费者组的偏移量,而客户端默认配置就是找不到偏移量之后,就取消息的最大偏移量,所以消费不了消息,但是不知道怎么解决,还请指导一下,谢谢