如何在Kafka中阻止消费者同时消费信息？
我有一个简单的Kafka消费者微服务应用程序，它使用来自某个主题的消息，同一个应用程序运行在两个不同的池中。
所以，当消息由制作人生成，而我的应用程序尝试使用来自主题的消息时，它只被一个池中的一个人使用。
如何停止从消费者Kafka读取并发消息。我想在两个池中使用相同的消息。
这种情况下可能的解决方案是什么
共有1个答案
如果您的主题只有一个分区，那么同一组中只有一个使用者。id设置可以读取此分区。如果您必须有一个分区才能进行排序，那么您需要唯一的组ID才能在多个使用者中读取此数据。
否则，如果主题有多个分区，那么应该有两个使用者主动阅读它们。
您可以通过不调用poll（）来“停止”阅读。
-
有什么方法可以阻止Kafka的消费者在一段时间内消费信息吗？我希望消费者停止一段时间，然后开始消费最后一条未消费的消息。
-
我有一个简单的Kafka设置。生成器正在以较高的速率向单个分区生成具有单个主题的消息。单个使用者正在使用来自此分区的消息。在此过程中，使用者可能会多次暂停处理消息。停顿可以持续几分钟。生产者停止产生消息后，所有排队的消息都将由使用者处理。生产者产生的消息似乎不会立即被消费者看到。我使用的是Kafka0.10.1.0。这里会发生什么？下面是使用消息的代码部分： 代理上的所有配置都保留为kafka默认
-
我正在使用带有KafkaListener注释的spring kafka v2.5.2。 在运行时，我希望能够向消费者发送停止消费的信号。 我看到了autoStartup参数，但它似乎只对初始化有效，之后无法更改。 我看到了KafkaListenerEndpointRegistry的methode close（）。。。 你有什么建议吗？ 提前谢谢。
-
由于它是一个Spring Boot应用程序，默认偏移量设置为Latest。我在这里做错了什么，请帮我弄明白。
-
本文向大家介绍Kafka 的消费者如何消费数据相关面试题，主要包含被问及Kafka 的消费者如何消费数据时的应答技巧和注意事项，需要的朋友参考一下 消费者每次消费数据的时候，消费者都会记录消费的物理偏移量（offset）的位置 等到下次消费时，他会接着上次位置继续消费
-
是否有一种方法以编程方式访问和打印使用者滞后偏移，或者说使用者读取的最后一条记录的偏移与某个生产者写入该使用者分区的最后一条记录的偏移之间的位置差。 要知道我的最终目标是将这个值发送到prometheus进行监视，我应该在上面添加哪些语句来得到滞后偏移值？