0
私はkafkaを学ぼうとしています。Zookeperサーバーとカフカをubuntu AWSノードにインストールしました.Zookeperサーバーを3つのブローカーとコンシューマと共に実行しています。Javaクライアント（kafka-clients0.9.0 .1）（私のラップトップ上の）私のMavenプロジェクトで、データをブローカーと消費者にawsで送信する。Kafka Clients jar JAVA
awtsでkafkaに接続するには、ローカルシステムでzookeeperとkafkaを実行する必要がありますか？ ローカルシステムにWindows 10があります。
カフカクラスタに接続している間、ブローカには次のように表示されます> INFO無効なリクエストにより/xx.xx.xx.xxへのソケット接続をクローズします：長さ1195725856のリクエストは無効です。最大サイズ104857600バイト。 （kafka.network.Processor）
いいえ、それは全く必要ありません。それがクライアントのイメージです。唯一必要なのは、Kafkaサーバーへのアクセスです。 – avr
こんにちは、私はzookeperサーバー（kafkaディレクトリ内）、3つのブローカーとaws上で実行されているトピックの消費者があります。しかし、私のクライアントコード（ローカルマシン）は、消費者にデータを送信することができません。何が問題なのでしょうか？ – user2966021
カフカ・ブローカー、カフカ・プロデューサー、カフカ・コンシューマーの違いを参照してください。1.カフカ・ブローカー（サーバー）は、データを保持する元のカフカ・サーバーです。2.カフカ・プロデューサー（クライアント）は、ブローカー3にデータを送信するカフカ・クライアントの1つです。クライアント）もKafka Broker（Server）からのデータを消費するKafkaクライアントの1つです。あなたのプロデューサーがカフカにアクセスできることを確認できますか？ポートが開かれているかどうか？ – avr