网站网站环境搭建教程,口碑好的定制网站建设提供商,会计招聘,高端网站设计定制1】确认 ZooKeeper 服务状态
为了进一步确认 ZooKeeper 服务的状态#xff0c;你可以执行以下操作#xff1a; 检查 ZooKeeper 服务状态#xff1a; docker ps 确保 ZooKeeper 容器正在运行。 检查 ZooKeeper 日志#xff1a; docker logs zookeeper 查看最新的日志条目你可以执行以下操作 检查 ZooKeeper 服务状态 docker ps 确保 ZooKeeper 容器正在运行。 检查 ZooKeeper 日志 docker logs zookeeper 查看最新的日志条目确保没有新的错误或警告信息。 测试 ZooKeeper 连接 使用 ncNetcat来测试 ZooKeeper 服务是否可以连接 docker exec -it kafka /bin/sh
nc -zv 110.40.130.231 2181 如果连接成功你会看到类似以下的输出 Connection to 110.40.130.231 2181 port [tcp/*] succeeded!
2】确认 Kafka 服务状态
若ZooKeeper 服务已经正常运行再认 Kafka 服务的状态 检查 Kafka 服务状态 docker ps 确保 Kafka 容器正在运行。 检查 Kafka 日志 docker logs kafka 查看最新的日志条目确保没有新的错误或警告信息。 测试 Kafka 生产和消费消息 使用 Kafka 的命令行工具来测试生产者和消费者的连接。首先进入 Kafka 容器 docker exec -it kafka /bin/sh 然后创建一个测试主题 /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-console-producer.sh --broker-list 110.40.130.231:9092 --topic test-topic 在另一个终端窗口中启动一个消费者来接收消息 docker exec -it kafka /bin/sh
/opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server 110.40.130.231:9092 --topic test-topic --from-beginning 如果一切正常在消费者端看到生产者发送的消息。 /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 端口。
