問題現象
消費用戶端使用“StickyAssignor”分配模式消費訊息時,發現同一個分區被多個消費線程消費,出現資料錯亂的情況。
可能原因
您的用戶端低於2.3版本。2.3版本以前的用戶端有可能將同一個分區分配給多個消費線程進行消費。
更多資訊,請參見開源Kafka相關問題說明。
解決方案
建議您升級用戶端至2.3或以上版本,或者換成其他分區分配策略。
使用建議:“StickyAssignor”分配策略目前在一些情況下會產生分配偏差,比如分區重複分配問題。如果不是業務特殊需求,不建議使用該分配策略。