kafka的消息不丢失配置心得

一、多消费者场景 1）每个消费者各自消费test2里面的数据（1to1 队列模式） 则多个消费者groupid设置成一样的值 2）每个消费者都去消费每一个消息（1toN订阅模式） 则多个消费者groupid设置成不一样的值 二、如果消费者中途重启发版，如何保证在重启后依然能够消费得到原来的消息 消费者增加下面配置即可 1）props.put(“linger.ms”, “50”); props.pu

>>阅读原文<<