Kafka で標準入力の代わりに単純なテキスト ファイルを読み込もうとしています。Kafka をダウンロードした後、次の手順を実行しました。
飼育係を開始しました:
bin/zookeeper-server-start.sh config/zookeeper.properties
起動したサーバー
bin/kafka-server-start.sh config/server.properties
「テスト」という名前のトピックを作成しました:
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
プロデューサーを実行しました:
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
Test1
Test2
消費者が聞いた:
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
Test1
Test2
標準入力の代わりに、コンシューマーが直接見ることができるデータ ファイルまたは単純なテキスト ファイルをプロデューサーに渡したいと考えています。どんな助けでも本当に感謝します。ありがとう！