【Kafka】kafka生产消费指令

aaacarrot / 2023-08-31 / 原文

推送kafka消息的指令:

bin/kafka-console-producer.sh --broker-list 10.1.12.100:9092 --topic setPointValue
这个指令执行入,就会进入一个输入指令的状态,就是 光标变成 ">" 的状态

kafka消息消费指令:

bin/kafka-console-consumer.sh --bootstrap-server 10.1.12.100:9092 --topic setPointValue
如果要指定 group_id,就这样写:
bin/kafka-console-consumer.sh --bootstrap-server 10.1.12.100:9092 --topic setPointValue --consumer-property group.id=test001