kafka的消息不丢失配置心得
一、多消费者场景
1)每个消费者各自消费test2里面的数据(1to1 队列模式)
则多个消费者groupid设置成一样的值
2)每个消费者都去消费每一个消息(1toN订阅模式)
则多个消费者groupid设置成不一样的值

二、如果消费者中途重启发版,如何保证在重启后依然能够消费得到原来的消息
消费者增加下面配置即可
1)props.put(“linger.ms”, “50”);
props.put(“acks”, “all”);
props.put("retries ", 30);
props.put("reconnect.backoff.ms ", 20000);
props.put(“retry.backoff.ms”, 20000);

相关文章:

  • 2022-12-23
  • 2021-11-02
  • 2021-09-13
  • 2021-06-21
  • 2022-01-06
  • 2022-02-21
  • 2022-12-23
  • 2021-06-17
猜你喜欢
  • 2021-10-27
  • 2021-09-28
  • 2022-12-23
  • 2022-12-23
  • 2021-08-12
  • 2022-01-21
相关资源
相似解决方案