kafka消费topic命令

Kafka消费topic的命令为：

bin/kafka-console-consumer.sh --bootstrap-server <kafka_host>:<kafka_port> --topic <topic_name> --from-beginning

其中，`<kafka_host>`是Kafka集群中任意一台服务器的主机名或IP地址，`<kafka_port>`是Kafka使用的端口号，一般为9092；`<topic_name>`是要消费的Topic的名称，`--from-beginning`表示从Topic的最早消息开始消费。

执行该命令后，即可在控制台上看到消费的消息。

相关问题

kafka创建topic命令_kafka常用命令总结

要在Kafka中创建一个新的topic，可以使用以下命令：

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic my-topic

这个命令做了以下几件事情：

- 使用`bin/kafka-topics.sh`命令行工具
- 使用`--create`参数来指示创建topic
- 使用`--zookeeper`参数来指定ZooKeeper的地址
- 使用`--replication-factor`参数来指定副本的数量
- 使用`--partitions`参数来指定分区的数量
- 使用`--topic`参数来指定新topic的名称

接下来是一些常用的Kafka命令：

- 创建topic: `bin/kafka-topics.sh --create ...`
- 查看topic列表: `bin/kafka-topics.sh --list ...`
- 查看topic的详细信息: `bin/kafka-topics.sh --describe ...`
- 删除topic: `bin/kafka-topics.sh --delete ...`
- 生产者发送消息: `bin/kafka-console-producer.sh ...`
- 消费者接收消息: `bin/kafka-console-consumer.sh ...`
- 查看Kafka集群中的消费者组: `bin/kafka-consumer-groups.sh ...`
- 重置消费者组的偏移量: `bin/kafka-consumer-groups.sh --reset-offsets ...`

这些命令可以帮助你管理Kafka集群并执行各种操作。

kafka消费速度命令

Kafka 提供了一套命令行工具 Kafka Console Consumer (kafka-consumer-groups.sh 或者 kafka-console-consumer) 来监控和控制消费者群组的消费进度。这个工具可以用于实时查看消费者的吞吐量、滞后时间等信息。

如果你想检查消费速度，你可以通过以下步骤操作：
1. **启动消费者**：

   bin/kafka-console-consumer.sh --bootstrap-server <brokers> --topic <topic_name> --from-beginning

这会从主题的开始位置开始消费，显示每条消息的速度。

2. **监控消费速率**：
消费者工具默认是以秒为单位显示处理的消息数，可以通过 `-max-messages` 参数限制消费的数量，这样可以看到一个时间段内的平均消费速率。

3. **查看性能指标**：
使用 `--metrics` 参数，可以查看实时的消费速率和其他性能指标，如 `Throughput in msg/s` 和 `Lag time in ms` 等。

4. **停止消费**：
结束消费时，只需按 `Ctrl+C`。