Kafka5:生产者与消费者命令

1. 生产者

• 在redis01机器上运行生产者命令

root@redis01:/usr/local/kafka# ./bin/kafka-console-producer.sh --bootstrap-server redis01:9092 --topic first
>hello
>henggao
>

2. 消费者

• 在redis02机器上运行消费者命令

# 查看增量数据
root@redis02:/usr/local/kafka# ./bin/kafka-console-consumer.sh --bootstrap-server redis01:9092 --topic first
# 查看历史和增量数据--from-beginning
root@redis02:/usr/local/kafka# ./bin/kafka-console-consumer.sh --bootstrap-server redis01:9092 --topic first --from-beginning