Kafka使用者配置-auto.offset.reset如何控制消息的使用
例如，我有一个消费者，最初在时间t1发送100条消息，然后我的消费者在t1+30秒启动并运行，那么我的消费者会使用t1+30秒之后发布的消息，还是会使用t1之后发布的消息？
共有1个答案
看情况.
auto.offset.reset仅在使用者组没有存储的偏移量时应用。
适用于下列情况：
-
null
-
我有一个需要使用Kafka Console Producer发送键值消息的用例。那么如何通过命令实现这一点呢？
-
我创建了一个接收器Kafka连接，将数据转换为其他存储;我想在使用 创建新连接器时将 设置为;我已经设置了配置; 但是当任务开始时，kafka 消费者仍然最早轮询记录;任何其他将 设置为最新版本的方法也是如此;
-
java 我正在使用控制中心来检查这个主题的消费者，并跟踪正在消费的数据。在运行这个应用程序时，它与Kafka和所有分区都连接得很好，我可以在控制中心看到所有的数据都被提取了，但在我的java控制台中没有打印任何数据。但是我注意到，在向Kafka发送一些新数据时，它会在java控制台中打印出来（即，在运行我的消费者后将新数据发送给Kafka）。它应该是这样的吗？还是我做错了什么？根据我的理解，Ka
-
我们使用的是spring集成kafka版本3.1.2。RELEASE and int kafka：消息驱动的通道适配器，用于使用来自远程kafka主题的消息。生产者发送加密消息，我们使用反序列化器解密实际消息。我们可以使用主题中发布的所有消息。我们将自动提交用作false。我们想知道在成功处理消息后如何从我们的服务提交或确认消息。有人能帮助我们如何提交从消息驱动通道读取的消息并提供一些参考实现吗？
-
我第一次在kafka中使用Node,使用Kafka-Node。使用消息需要调用外部API，这甚至可能需要一秒钟的时间来响应。我希望克服我的消费者的突然失败，这样，如果一个消费者失败了，另一个将替换它的消费者将收到相同的消息，即它的工作没有完成。 我正在使用Kafka0.10并尝试使用ConsumerGroup。 我想到了在options中设置，并且只在消息的工作完成后提交消息（就像我以前对一些Ja
-
我正在为Kafka0.9.0.0做Kafka快速入门。 我让zookeeper在监听，因为我运行了 只有一个代理在处侦听，因为我运行了 我有一个制作人在主题“测试”上发帖，因为我跑了 当我运行旧的API使用者时，它通过运行 但是，当我运行新的API使用者时，我在运行时没有得到任何东西 是否可以使用新的API从控制台使用者订阅主题？我该怎么修好它？