kafka-console-consumer.sh 读当前最新的消息
时间: 2023-09-29 19:09:30 浏览: 251
kafka消息可视化查看工具
如果您想在 Kafka 中使用 kafka-console-consumer.sh 读取当前最新的消息,可以使用以下命令:
```
./kafka-console-consumer.sh --bootstrap-server <kafka-broker>:<port> --topic <topic> --from-beginning --timeout-ms 1000 --max-messages 1
```
其中,`<kafka-broker>:<port>` 是 Kafka 服务器的地址和端口,`<topic>` 是您要读取的主题名称。`--from-beginning` 参数表示从最早的消息开始读取,`--timeout-ms 1000` 表示等待消息的时间为 1000 毫秒,`--max-messages 1` 表示只读取一条消息。
执行这个命令后,您将会看到最新的一条消息的内容。如果没有新消息,命令将会一直等待,直到有新消息到来。
阅读全文