跳到主要内容

04、Kafka 实战 - 实现生产者和消费者

生产者和消费者

创建主题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

⼏个注意点：

  • 消息会被存储
  • 消息是顺序存储
  • 消息是有偏移量的
  • 消费时可以指明偏移量进⾏消费