Kafka-消费者如何避免消息积压+消费常用模式+配置参数

一、 常用消费者的消费模式 多个消费线程可以在一个进程中，也可以在不同进程中 消费线程负责拉取数据，每一条消费放到一个线程池负责业务逻辑的处理 如果要保证消息有序这种模式不行 自动提交偏移量 可能丢失，可以调小自动提交偏移量的时间间隔，减少丢失的数量和丢失的概率 可能重复，需要做幂等处理 手动提交偏移量 消费者自己维护需要提交的偏移量，按照不同分区维护 消费自己控制提交偏移量的时机，什么时候提交

>>阅读原文<<