1
我在馬拉松容器中運行了kafka conenct。如果我想更新連接器插件(jar),我必須上傳新插件,然後重新啓動連接任務。如何更新正在運行的kafka連接器
有沒有可能做到這一點,而無需重新啓動/停機時間?
我在馬拉松容器中運行了kafka conenct。如果我想更新連接器插件(jar),我必須上傳新插件,然後重新啓動連接任務。如何更新正在運行的kafka連接器
有沒有可能做到這一點,而無需重新啓動/停機時間?
連接器插件的更新jar需要添加到類路徑中,然後工作者的類加載器需要將其拾取。目前做這件事的最好方法是按照here的描述進行停電。
根據您的連接器,您可能可以進行滾動升級,但一般的答案是,如果您需要升級連接器插件,則您當前必須停機。
此外,絕大多數連接器在滾動升級時都可以正常工作。因此,在許多情況下,如果您使Connect在分佈式模式下運行,則不需要停機。不過,正如@dawsaw所說,這取決於連接器是否以兼容的方式寫入(而不僅僅是向後兼容,因爲在升級期間,分配可能會在連接器的舊版本和新版本之間切換)。 –