ubuntu

如何测试Ubuntu Kafka配置的正确性

小樊
40
2025-05-10 16:54:10
栏目: 智能运维

要测试Ubuntu上的Kafka配置是否正确,可以按照以下步骤进行操作:

  1. 启动Kafka和Zookeeper服务

    • 确保Zookeeper服务已经启动:
      /opt/kafka_2.13-3.5.2/bin/zookeeper-server-start.sh /opt/kafka_2.13-3.5.2/config/zookeeper.properties
      
    • 启动Kafka服务:
      /opt/kafka_2.13-3.5.2/bin/kafka-server-start.sh /opt/kafka_2.13-3.5.2/config/server.properties
      
  2. 验证Kafka是否启动成功

    • 使用以下命令检查Kafka是否正在监听9092端口:
      netstat -tulnp | grep 9092
      
    • 你应该能看到类似以下的输出,表示Kafka服务器正在监听9092端口:
      tcp        0      0 0.0.0.0:9092            0.0.0.0:*               LISTEN
      
  3. 创建一个测试Topic

    • 使用以下命令创建一个名为test的Topic,副本因子为1,分区数为1:
      /opt/kafka_2.13-3.5.2/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
      
  4. 验证Topic是否创建成功

    • 使用以下命令列出所有Topic以确认test Topic已创建:
      /opt/kafka_2.13-3.5.2/bin/kafka-topics.sh --list --zookeeper localhost:2181
      
  5. 测试生产者和消费者

    • 启动生产者:
      /opt/kafka_2.13-3.5.2/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
      
    • 在生产者终端输入消息后按Ctrl+D结束输入。
    • 启动消费者:
      /opt/kafka_2.13-3.5.2/bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
      
    • 在消费者终端中,你应该能看到从生产者发送的消息。

通过以上步骤,你可以验证Kafka是否配置正确并且能够正常运行。如果生产者和消费者能够成功地发送和接收消息,说明Kafka配置成功。

0
看了该问题的人还看了