Skip to content

Latest commit

 

History

History
53 lines (31 loc) · 1.72 KB

README.md

File metadata and controls

53 lines (31 loc) · 1.72 KB

connector

在最初設定中有填入worker相關資訊,即可以在此區域檢視與管理worker

此專案建立之worler預設plugin位置在tmp/worker-plugins

basic

檢視當前worker所執行中的connector其名稱、狀態與參數內容,如需要可以在此頁面刪除connector

connector_basic_1.png

task

當下worker所執行之task創建資訊與其當下統計之狀態

task有出現error時,會在error field 展示其 exception 內容

connector_task_1.png 因缺少jar檔,因此出現錯誤並顯示在 error field中

create

可以透過 gui 在此 worker創建所需要之connector,創建完成時會在下方顯示創造出來的connector

提醒:Kafka 預設會使用 json convert來處理 records,因此如果使用本專案的backup工具, 需要將 converter設定為 org.apache.kafka.connect.converters.ByteArrayConverter

詳情可以至Exporter查看

connector_create_1.png

active workers

顯示當下所執行之 worker,包含資訊有執行connector,task數量、版本與cluster id等資訊

connector_active_workers_1.png

plugin

可以檢視此worker以安裝之plugin資訊與其文件,兩者都可以透過query進行搜尋與過濾

connector_plugin_1.png worker所有可使用之plugin與相關資訊

connector_plugin_2.png plugin的其說明文件,有其所需之參數之說明