aopstudio 的个人博客

记录精彩的程序人生

AOP=art of programming=编程的艺术=程艺
  menu
35 文章
0 浏览
6 当前访客
ღゝ◡╹)ノ❤️

记录一下成功运行Kafka的过程

在保证本地Java环境安装以及配置成功的情况下,Kafka的运行比我想象中容易不少,也没有出现奇奇怪怪的报错。

  1. 去官网(Apache Kafka)下载二进制包并解压

  2. 在终端窗口进入解压后的目录后,执行以下命令启动zookeeper:

    ./bin/zookeeper-server-start.sh config/zookeeper.properties
    

    启动之后,保留这个终端窗口不要关闭

  3. 新开一个终端窗口,在同一目录,执行以下命令启动Kafka服务:

    ./bin/kafka-server-start.sh config/server.properties
    

    同样,启动之后,保留这个终端窗口不要关闭

  4. 再开一个终端窗口,用来创建topic。执行以下命令:

    ./bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test-topic
    

    test-topic是我们创建的topic的名称,可以随自己定。这个命令执行完之后,可以关掉终端窗口,也可以不关,直接在这个窗口里执行下一步操作。

  5. 执行以下命令启动一个生产者

    ./bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic test-topic
    

    现在,可以在该窗口中输入想要发送到消息队列的信息。

  6. 打开另一个新的终端窗口,进入 Kafka 目录,并使用以下命令启动消息消费者:

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

    这时候会发现,之前在生产者中发送的消息会显示在消费者的终端窗口中。

但是这样启动消费者会有一个问题,每次重启消费者之后都会从头消费所有生产者以及产生的消息。如果想要消费者这边只消费新的消息,不消费已经消费过的消息,就需要将消费者加入用户组后启动。具体命令如下:

./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test-topic --group my-consumer-group

标题:记录一下成功运行Kafka的过程
作者:aopstudio
地址:https://neusoftware.top/articles/2023/10/08/1696771401758.html