【win 10 Kafka基本操作】topicの起動、作成、メッセージ送信


1、Zookeeperを起動する
Kafkaはzookeeperに依存するため、まずzookeeperを起動し、kafkaに内蔵されたzookeeper、cdをkafkaのbin\windowsディレクトリの下で、次のコマンドを実行してzookeeperを起動する必要があり、zookeeper.propertiesの経路zookeeper-server-startを指定する必要がある.bat D:\kafka_2.11-1.0.0\kafka_2.11-1.0.0\config\zookeeper.properties
2、Kafkaを起動する
zookeeperを起動すると、同様にkafkaのbin\windowsディレクトリで次のコマンドを実行してkafkaを起動し、server.propertiesのパスkafka-server-startを指定する必要がある.bat D:\kafka_2.11-1.0.0\kafka_2.11-1.0.0\config\server.properties
次のbatスクリプトを使用してzookeeperとkafkaを一度に起動できます(cmd/kはコマンドを実行した後、コマンドウィンドウを閉じません).
echo start Zookeeper
start cmd /k call D:\kafka_2.11-1.0.0\kafka_2.11-1.0.0\bin\windows\zookeeper-server-start.bat D:\kafka_2.11-1.0.0\kafka_2.11-1.0.0\config\zookeeper.properties

echo start Kafka
start cmd /k call D:\kafka_2.11-1.0.0\kafka_2.11-1.0.0\bin\windows\kafka-server-start.bat D:\kafka_2.11-1.0.0\kafka_2.11-1.0.0\config\server.properties

3、テーマの作成
kafkaのbin\windowsディレクトリの下で、topic_demoというトピックkafka-topicsを作成するコマンドを実行します.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic topic_demo
4、生産情報
kafkaのbin\windowsディレクトリの下で次のコマンドを実行してトピックtopic_demoに情報を送信し、コマンドラインに絶えず入力して車に戻るだけでkafka-console-producer.bat --broker-list localhost:9092 --topic topic_demo
5、消費情報
kafkaのbin\windowsディレクトリの下で、トピックtopic_demoから生成する情報kafka-console-consumerを受け入れるコマンドを実行する.bat --bootstrap-server localhost:9092 --topic topic_demo --from-beginning