將kafka客戶端從0.8.0升級到0.10.0.1時是否會有數據丟失？

Question

我們計劃將Kafka客戶端從0.8.0升級到0.10.0.1，但由於消費者在0.8.0版本中的偏移量存儲在zookeeper中，因爲它存儲在0.10.0.1版本的代理中，與0.10.0.1中的版本0.8.0相同的組和客戶端ID，則新消費者將從舊消費者停止消費的地方獲取消息。如果數據丟失即將發生，我們可以嘗試將偏移量從zookeeper遷移到代理商，然後啓動我們的新消費者。

Answer 1

您可以繼續在0.10的zookeeper中存儲偏移量。事實上，如果您只是升級客戶端二進制文件，您將看不到偏移量提交行爲的任何更改。如果您需要開始考慮遷移數據和偏移量，那麼當您轉向在應用程序中使用新的客戶API時。這是您需要停止基於舊API的舊應用程序實例，檢查存儲在zookeeper中的偏移量，然後從該偏移量開始新的使用者API實現以避免數據丟失或重複。