Skip to main content
Data Infrastructure Insights
本繁體中文版使用機器翻譯，譯文僅供參考，若與英文版本牴觸，應以英文版本為準。

Kafka資料收集器

貢獻者
PDF

Data Infrastructure Insights 使用此資料收集器從 Kafka 收集指標。

安裝

  1. 從 * 可伺服 > 收集器 * 、按一下 * + 資料收集器 * 。選擇 Kafka 。

    選取安裝Telegraf代理程式的作業系統或平台。

  2. 如果您尚未安裝 Agent 進行收集，或想要為不同的作業系統或平台安裝 Agent ，請按一下 _ 顯示指示 _ 以展開指示"代理程式安裝"。

  3. 選取要搭配此資料收集器使用的代理程式存取金鑰。您可以按一下「+代理程式存取金鑰」按鈕來新增代理存取金鑰。最佳實務做法：只有當您想要將資料收集器分組時、才使用不同的代理程式存取金鑰、例如依作業系統/平台。

  4. 請依照組態步驟設定資料收集器。這些指示會因您用來收集資料的作業系統或平台類型而有所不同。

Kafka組態

設定

Kafka外掛程式是以Telewraf的Jolokia外掛程式為基礎。例如、需要從所有的Kafka代理商收集資訊、需要透過Jolkia設定和公開所有元件的JMX。

相容性

組態是針對Kafka 0.11.0.2版所開發。

設定

以下所有指示均假設您的Kafka安裝位置為「/opt/Kafka」。您可以調整下列指示、以反映您的安裝位置。

Jolokia代理程式Jar

Jlokia 代理程式 Jar 檔案必須是"已下載"的版本。測試的版本是Joslokia代理1.6.0.

以下說明假設下載的Jar檔案（jolokia -jvm-1.6.0-agent.jar）位於「/opt / Kafka/libs/」的位置。

卡夫卡經紀人

若要設定Kafka代理商以公開Jolokia API、您可以在「Kafka-rer-class.sh」通話之前、在<Kafka_hom>/bin/Kafka-server-start.sh中新增下列項目：

export JMX_PORT=9999
export RMI_HOSTNAME=`hostname -I`
export KAFKA_JMX_OPTS="-javaagent:/opt/kafka/libs/jolokia-jvm-1.6.0-agent.jar=port=8778,host=0.0.0.0  -Dcom.sun.management.jmxremote.password.file=/opt/kafka/config/jmxremote.password -Dcom.sun.management.jmxremote.ssl=false -Djava.rmi.server.hostname=$RMI_HOSTNAME -Dcom.sun.management.jmxremote.rmi.port=$JMX_PORT"

請注意、上述範例使用「主機名稱-I」來設定「RMI_HOSTNAME」環境變數。在多個IP機器中、需要調整此設定、才能收集您所關心的RMI連線IP。

您可以為JMx（上方9999）和Joslokia（8778）選擇不同的連接埠。如果您有內部IP來鎖定Jolokia、您可以用自己的IP來取代「全部抓出」0．0．0。請注意、此IP必須從遠端工作人員外掛程式存取。如果您不想驗證、可以使用「-Dcom.sun.management.jmxremote.authenticate=false'」選項。使用風險由您自行承擔。

物件與計數器

收集下列物件及其計數器：

物件： 識別碼： 屬性：

卡夫卡代理人

叢集命名空間代理

節點名稱節點IP

疑難排解

您可以在頁面中找到其他資訊"支援"。