漏消費和重復消費

重復消費：已經消費了數據，但是 offset 沒提交。
漏消費：先提交 offset 后消費，有可能會造成數據的漏消費。

消費者事務

如果想完成Consumer端的精準一次性消費，那么需要Kafka消費端將消費過程和提交offset過程做原子綁定。此時我們需要將Kafka的offset保存到支持事務的自定義介質（比 如MySQL）。

數據積壓（消費者如何提高吞吐量）

1）如果是Kafka消費能力不足，則可以考慮增加Topic的分區數，并且同時提升消費組的消費者數量，消費者數 = 分區數。（兩者缺一不可）

2）如果是下游的數據處理不及時：提高每批次拉取的數量。批次拉取數據過少（拉取數據/處理時間 < 生產速度），使處理的數據小于生產的數據，也會造成數據積壓。