kafka测试

1】确认 ZooKeeper 服务状态

为了进一步确认 ZooKeeper 服务的状态，你可以实行以下操作：

• 检查 ZooKeeper 服务状态：
  
  1. docker ps

  复制代码
  确保 ZooKeeper 容器正在运行。
  
• 检查 ZooKeeper 日志：
  
  1. docker logs zookeeper

  复制代码
  检察最新的日志条目，确保没有新的错误或告诫信息。
  
• 测试 ZooKeeper 连接：
    利用 nc（Netcat）来测试 ZooKeeper 服务是否可以连接：
  
  1. docker exec -it kafka /bin/sh
  2. nc -zv 110.40.130.231 2181

  复制代码
  如果连接乐成，你会看到类似以下的输出：
  
  1. Connection to 110.40.130.231 2181 port [tcp/*] succeeded!

  复制代码

2】确认 Kafka 服务状态

若ZooKeeper 服务已经正常运行，再认 Kafka 服务的状态：

• 检查 Kafka 服务状态：
  
  1. docker ps

  复制代码
  确保 Kafka 容器正在运行。
  
• 检查 Kafka 日志：
  
  1. docker logs kafka

  复制代码
  检察最新的日志条目，确保没有新的错误或告诫信息。
  
• 测试 Kafka 生产和消费消息：
    利用 Kafka 的命令行工具来测试生产者和消费者的连接。起首，进入 Kafka 容器：
  
  1. docker exec -it kafka /bin/sh

  复制代码
  然后，创建一个测试主题：
  
  1. /opt/kafka/bin/kafka-topics.sh --create --topic test-topic --partitions 1 --replication-factor 1 --zookeeper 110.40.130.231:2181

  复制代码
  发送一些测试消息：
  
  1. /opt/kafka/bin/kafka-console-producer.sh --broker-list 110.40.130.231:9092 --topic test-topic

  复制代码
  在另一个终端窗口中，启动一个消费者来接收消息：
  
  1. docker exec -it kafka /bin/sh
  2. /opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server 110.40.130.231:9092 --topic test-topic --from-beginning

  复制代码
  如果统统正常，在消费者端看到生产者发送的消息。
  

---

1. /opt/kafka/bin/kafka-topics.sh --create --topic test-topic --partitions 1 --replication-factor 1 --zookeeper 110.40.130.231:2181

复制代码

详细表明

• /opt/kafka/bin/kafka-topics.sh:
  
  
  
  • 这是 Kafka 提供的命令行工具之一，用于管理和操作 Kafka 主题。
    
  • 路径 /opt/kafka/bin 是 Kafka 安装目录下的 bin 目录，此中包含了各种 Kafka 命令行工具。
    
  
  
• --create:
  
  
  
  • 这个选项表示要创建一个新的主题。
    
  • 其他常用选项包括 --list（列出所有主题）、--describe（描述特定主题的详细信息）、--delete（删除主题）等。
    
  
  
• --topic test-topic:
  
  
  
  • 这个选项指定了要创建的主题的名称。
    
  • test-topic 是选择的主题名称，你可以根据需要将其更换为任何其他名称。
    
  
  
• --partitions 1:
  
  
  
  • 这个选项指定了主题的分区数。
    
  • 分区是 Kafka 中的一个告急概念，用于实现程度扩展和并行处理。每个分区可以独立地存储和处理消息。
    
  • 在这个例子中，1 表示该主题将只有一个分区。
    
  
  
• --replication-factor 1:
  
  
  
  • 这个选项指定了主题的副本因子。
    
  • 副本因子决定了每个分区的数据在多少个不同的 Kafka 署理（broker）上进行复制，以提高可用性和容错性。
    
  • 在这个例子中，1 表示每个分区只有一个副本，这意味着没有冗余备份。如果你希望增加冗余，可以将此值设置为大于 1 的数字，例如 2 或 3。
    
  
  
• --zookeeper 110.40.130.231:2181:
  
  
  
  • 这个选项指定了 ZooKeeper 的地址和端口。
    
  • ZooKeeper 是一个分布式协调服务，Kafka 利用它来管理集群的元数据，包括主题、分区和副本的信息。
    
  • 110.40.130.231 是 ZooKeeper 服务器的 IP 地址，2181 是默认的 ZooKeeper 端口。
    
  
  

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。