生产者和消费者
创建主题topic
topic是什么概念？topic可以实现消息的分类，不同消费者订阅不同的topic
- 执⾏以下命令创建名为“test”的topic，这个topic只有⼀个partition，并且备份因⼦也设置为1：
./kafka-topics.sh \
--create \
--zookeeper 172.16.253.35:2181 \
--replicationfactor 1 \
--partitions 1 \
--topic test
- 查看当前kafka内有哪些topic
./kafka-topics.sh \
--list \
--zookeeper 172.16.253.35:2181
发送消息
kafka⾃带了⼀个producer命令客户端，可以从本地⽂件中读取内容，或者我们也可以以命令⾏中直接输⼊内容，并将这些内容以消息的形式发送到kafka集群中。在默认情况下，每⼀个⾏会被当做成⼀个独⽴的消息。使⽤kafka的发送消息的客户端，指定发送到的kafka服务器地址和topic
./kafka-console-producer.sh \
--broker-list 172.16.253.38:9092 \
--topic test
消费消息
对于consumer，kafka同样也携带了⼀个命令⾏客户端，会将获取到内容在命令中进⾏输出，默认是消费最新的消息。使⽤kafka的消费者消息的客户端，从指定kafka服务器的指定topic中消费消息
- ⽅式⼀：从最后⼀条消息的偏移量+1开始消费
./kafka-console-consumer.sh \
--bootstrap-server 172.16.253.38:9092 \
--topic test
- ⽅式⼆：从头开始消费
./kafka-console-consumer.sh \
--bootstrap-server 172.16.253.38:9092 \
--from-beginning \
--topic test
⼏个注意点：
- 消息会被存储
- 消息是顺序存储
- 消息是有偏移量的
- 消费时可以指明偏移量进⾏消费
版权声明：本文不是「本站」原创文章，版权归原作者所有 | 原文地址: