|
|
@@ -122,7 +122,7 @@ ls /brokers/ids/
|
|
|
kafka⾃带了⼀个producer命令客户端，可以从本地⽂件中读取内容，或者我们也可以以命令⾏中直接输⼊内容，并将这些内容以消息的形式发送到kafka集群中。在默认情况下，每⼀个⾏会被当做成⼀个独⽴的消息。使⽤kafka的发送消息的客户端，指定发送到的kafka服务器地址和topic
|
|
|
|
|
|
```
|
|
|
-./kafka-console-consumer.sh --bootstrap-server 192.168.245.21:9092 --topic test
|
|
|
+./kafka-console-producer.sh --broker-list 192.168.245.21:9092 --topic test
|
|
|
```
|
|
|
|
|
|
|
|
|
@@ -137,8 +137,7 @@ kafka⾃带了⼀个producer命令客户端，可以从本地⽂件中读取内
|
|
|
```
|
|
|
* ⽅式⼆：从头开始消费
|
|
|
```
|
|
|
-./kafka-console-consumer.sh --bootstrap-server 192.168.245.21:9092 --
|
|
|
-from-beginning --topic test
|
|
|
+./kafka-console-consumer.sh --bootstrap-server 192.168.245.21:9092 --from-beginning --topic test
|
|
|
```
|
|
|
|
|
|
|
