Kafka-消費者如何避免消息積壓+消費常用模式+配置參數

一、 常用消費者的消費模式 多個消費線程可以在一個進程中，也可以在不同進程中 消費線程負責拉取數據，每一條消費放到一個線程池負責業務邏輯的處理 如果要保證消息有序這種模式不行 自動提交偏移量 可能丟失，可以調小自動提交偏移量的時間間隔，減少丟失的數量和丟失的概率 可能重複，需要做冪等處理 手動提交偏移量 消費者自己維護需要提交的偏移量，按照不同分區維護 消費自己控制提交偏移量的時機，什麼時候提交

>>阅读原文<<