Apache Kafka - コンシューマーファンダメンタルズ

Question

私は、私の会社のブローカーに接続するためにApache Kafkaを使用する必要があります。問題はこれまで私がこの技術を使ったことがないことです。これは私が少し明確にする必要があるものです。

実際に、〜/ bin/kafka-console-consumer.sh --zookeeper localhost：2181 --topic testGaultier --from-コマンドで動作するZookeeper/Server/Consumerで "ローカル" Kafkaを作成しました。はじめに

サーバー/プロデューサがすでに別の人によって管理されている別のケースでは、コンシューマを作成するだけです。 消費者を作るためにカフカのパッケージ全体をダウンロードする必要がありますか、それとも別の方法ですか？私はデータの修復だけをしたいと思います。

ありがとうございます！ :)

Answer 1

コンソールコンシューマを使用する場合は、ローカルインスタンスの場合とまったく同じですが、コンシューマを起動するときに、kafkaサーバの動物園とトピック名を指定するようになりました。

カスタムコンシューマを作成する場合は、JavaコンシューマAPIまたはgoogleを使用して別の言語のAPIを使用できます。

最初のケースでは、すべての必要なスクリプトとクラスがあるので、Kafkaパッケージをダウンロードする必要があります。 2番目のケースでは、これを行う必要はありません。