Kafka之消息发送和读取命令

消息发送

启动一个命令行producer进行消息的发送

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

消息读取

启动一个命令行consumer进行消息的读取

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

—from-beginning 指定从开头进行读取，也就是说每次运行上述命令都会打印所有消息，不加参数则只会从启动时刻起开始打印接收到的消息。