有个接口消费 Kafka,测试发现消费一直在堆积没有减少。 问题背景 有个接口消费 Kafka,测试发现消费一直在堆积没有减少。在日志中打印出 partition,发现都是 partition:0, offset:203 ,说明有大量重复消费的问题,把日志里面收到的同一条消息(同一个 partition 和 offset)的时间戳都筛选出来。 1 2 3 4 5 6 7 8 9 10 11 12 …
有个接口消费 Kafka,测试发现消费一直在堆积没有减少。 问题背景 有个接口消费 Kafka,测试发现消费一直在堆积没有减少。在日志中打印出 partition,发现都是 partition:0, offset:203 ,说明有大量重复消费的问题,把日志里面收到的同一条消息(同一个 partition 和 offset)的时间戳都筛选出来。 1 2 3 4 5 6 7 8 9 10 11 12 …
讨论
登录后参与讨论
还没有评论,来说第一句吧。