Apache Kafka - 消費者基礎知識

Question

我必須使用Apache Kafka連接到我公司的經紀人。問題是我以前從未使用過這種技術，這是我需要澄清的一點。

實際上，我創建了一個帶有Zookeeper/Server/Consumer的「本地」Kafka，它與命令〜/ bin/kafka-console-consumer.sh一起工作--zookeeper localhost：2181 --topic testGaultier --from-開始

我現在在另一個情況下，服務器/生產者已經由另一個人管理，我只需要創建一個消費者。 是否有必要下載Kafka的整個包來創建消費者，還是有另一種方式？我只想恢復數據。

謝謝！ :)

Answer 1

如果您想使用控制檯使用者，那麼它與您爲本地實例完全相同，但是現在在啓動使用者時指定kafka服務器的zookeeper和主題名稱。

或者，如果您要創建自定義使用者，則可以使用Java使用者API或Google獲取其他語言的API。

在第一種情況下，您必須下載Kafka軟件包，因爲它具有所有必需的腳本和類。對於第二種情況，不需要這樣做。