kafka-console-consumer.sh 从指定时间戳开始消费

可以使用 `--timestamp` 参数来指定从哪个时间戳开始消费，命令格式如下：

kafka-console-consumer.sh --bootstrap-server <broker_host>:<broker_port> --topic <topic_name> --from-beginning --timestamp <timestamp>

其中 `<timestamp>` 是以毫秒为单位的时间戳，表示从该时间戳开始消费。注意，这个时间戳必须是已经存在于某个消息的 `timestamp` 属性中的时间戳，否则不会有任何消息被消费。

此外，为了确保消费者能够消费到指定时间戳之前的所有消息，需要使用 `--from-beginning` 参数来让消费者从最早的消息开始消费。

相关问题

Kafka-console-consumer.sh 详细介绍

kafka-console-consumer.sh 是 Apache Kafka 提供的一个命令行工具，用于从 Kafka 消费者订阅的主题中读取消息并打印到控制台。它可以用来测试 Kafka 集群是否正常工作，检查主题中是否有消息，以及实时监控消息的流动情况。

kafka-console-consumer.sh 命令的用法如下：

bin/kafka-console-consumer.sh --bootstrap-server <hostname>:<port> --topic <topic-name> [--from-beginning]

其中，--bootstrap-server 参数指定 Kafka 集群的地址和端口；--topic 参数指定消费者订阅的主题名称；--from-beginning 参数可选，表示从主题的起始位置开始消费，如果不指定，则只消费最新的消息。

此外，kafka-console-consumer.sh 还支持一些其他的参数，例如可以将消息输出到文件或者指定消费者组等。更多详细信息可以通过执行 `bin/kafka-console-consumer.sh --help` 命令查看。

kafka-console-producer.sh可以发送消息到topic，但是kafka-console-consumer.sh消费不到消息

出现这种情况可能有以下几个原因：

1. 确认kafka集群是否正常运行，可以使用命令`kafka-topics.sh --list --zookeeper <zookeeper_host:port>`查看topic列表是否正确。
2. 确认producer发送到正确的topic，可以使用命令`kafka-console-consumer.sh --bootstrap-server <kafka_host:port> --topic <topic_name> --from-beginning`尝试消费消息。
3. 确认consumer连接的kafka集群是否正确，可以使用命令`kafka-console-consumer.sh --bootstrap-server <kafka_host:port> --topic <topic_name> --from-beginning`尝试消费消息。
4. 如果是在同一台机器上测试，可能是因为producer和consumer使用了不同的kafka配置文件，可以尝试将它们都使用同一个配置文件。

如果以上几个原因都排除掉了，还是无法消费到消息，可以查看kafka日志文件，确认是否有异常报错，进一步分析问题所在。