如何在Kafka的消费者关闭的情况下读取最后一次消费的消息后的消息？
我有一种在shell中执行此任务的方法：如何使kafka消费者从上次消耗的偏移量读取，而不是从开始读取
但是，我愿意在Python中这样做，使用Kafka-蟒蛇
我找不到任何关于这种情况的api。
http://kafka-python.readthedocs.io/en/latest/apidoc/KafkaConsumer.html
共有1个答案
要使用< code>kafka-python启用使用者组，您只需在使用者中设置< code>group_id配置。
从消费者API：
group_id（str或无）-要加入的用于动态分区分配（如果启用）以及用于获取和提交偏移的消费者组的名称。如果无，则禁用自动分区分配（通过组协调器）和偏移提交。默认值：无
如果您将其设置为任何值，消费者将自动提交它读取的偏移量，并从该位置重新启动，以防关闭。
-
是否有一种方法以编程方式访问和打印使用者滞后偏移，或者说使用者读取的最后一条记录的偏移与某个生产者写入该使用者分区的最后一条记录的偏移之间的位置差。 要知道我的最终目标是将这个值发送到prometheus进行监视，我应该在上面添加哪些语句来得到滞后偏移值？
-
我将python kafka consumer的< code>auto_commit设置为< code>False，我正在手动提交消息。然而，重启后，消费者再次消费来自每个分区的最后一条消息。只有最后一个，不能再多。 这就是所展示的： 不知道为什么会显示滞后，whu当前偏移设置为最后一条消息而不是下一条？当我提交偏移量3时，当前偏移量不应该移动到4吗？ 我提交我使用的每条消息，但是在重启时，它总是
-
我正在尝试让 kafka 消费者获取在 Java 中生成并发布到主题的消息。我的消费者如下。 consumer.java 当我运行上面的代码时，我在控制台中什么也看不到，屏幕后面的java producer程序正在‘AATest’主题下不断地发布数据。另外，在动物园管理员控制台中，当我尝试运行上面的consumer.java时，我得到了以下行 此外，当我运行指向 AATest 主题的单独控制台使用
-
我有一个生产者和一个消费者。消费者的多个实例正在运行。当生产者发布消息时，我的意图是通过所有实例消费该消息。所以，我使用的是直接交换。生产者将带有主题的消息发布到直接交换。消费者正在通过独占队列收听该主题。当消费者启动并且生产者发布消息时，此过程运行良好。但是当消费者关闭并且生产者发布消息时，消费者在启动时不会消费此消息。 我在谷歌上搜索了这个问题。建议使用命名队列。但是，如果使用命名队列，则消息
-
由于它是一个Spring Boot应用程序，默认偏移量设置为Latest。我在这里做错了什么，请帮我弄明白。
-
我有一个简单的Kafka设置。生成器正在以较高的速率向单个分区生成具有单个主题的消息。单个使用者正在使用来自此分区的消息。在此过程中，使用者可能会多次暂停处理消息。停顿可以持续几分钟。生产者停止产生消息后，所有排队的消息都将由使用者处理。生产者产生的消息似乎不会立即被消费者看到。我使用的是Kafka0.10.1.0。这里会发生什么？下面是使用消息的代码部分： 代理上的所有配置都保留为kafka默认