kafka 命令行查看所有 topic
时间: 2023-07-03 08:19:48 浏览: 87
要查看 Kafka 中的所有 topic,可以使用以下命令行:
```
bin/kafka-topics.sh --list --zookeeper <zk_host>:<zk_port>
```
其中 `<zk_host>` 是 ZooKeeper 的主机名或 IP 地址,`<zk_port>` 是 ZooKeeper 的端口号。该命令将返回所有 topic 的名称列表。
相关问题
kafka 命令行查看 Consumer Group
可以使用 Kafka 自带的命令行工具 kafka-consumer-groups.sh 来查看 Consumer Group 的状态。该工具可以列出当前 Consumer Group 中所有消费者的状态,以及它们消费的 Topic 和分区信息。
以下是查看 Consumer Group 状态的命令行示例:
```
kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group my-group
```
其中,--bootstrap-server 参数指定 Kafka 的服务器地址和端口号,--describe 参数表示列出 Consumer Group 的详细信息,--group 参数指定 Consumer Group 的名称。
执行该命令后,会列出该 Consumer Group 中所有消费者的详细信息,包括消费者 ID、所消费的 Topic 和分区、当前消费的偏移量等。这些信息可以帮助我们了解 Consumer Group 的状态,以及每个消费者的消费情况。
kafka命令行操作
Kafka 是一个分布式流处理平台,它常用于构建高性能、可扩展的实时数据流应用程序。下面是一些常用的 Kafka 命令行操作:
1. 启动 Kafka 服务器:
```
bin/kafka-server-start.sh config/server.properties
```
2. 创建一个主题(Topic):
```
bin/kafka-topics.sh --create --topic <topic_name> --bootstrap-server <broker_host:port> --partitions <num_partitions> --replication-factor <replication_factor>
```
3. 列出所有主题:
```
bin/kafka-topics.sh --list --bootstrap-server <broker_host:port>
```
4. 查看主题详情:
```
bin/kafka-topics.sh --describe --topic <topic_name> --bootstrap-server <broker_host:port>
```
5. 发送消息到主题:
```
bin/kafka-console-producer.sh --topic <topic_name> --bootstrap-server <broker_host:port>
```
6. 从主题消费消息:
```
bin/kafka-console-consumer.sh --topic <topic_name> --bootstrap-server <broker_host:port> [--from-beginning]
```
这些是一些常见的 Kafka 命令行操作,你可以根据需要进行调整和组合使用。请注意,<topic_name> 是你要创建或操作的主题名称,<broker_host:port> 是 Kafka 服务器的地址和端口,<num_partitions> 是主题的分区数,<replication_factor> 是主题的副本因子。