我们能听Kafka消费者的特定键控信息吗
我对Kafka很陌生。我有一个要求，在那里我只需要阅读一些特定的消息。
共有1个答案
我能想到的唯一方法是，您可以将您的使用者分配给发布者使用您感兴趣的密钥向其发送消息的分区。您还需要编写自己的分区器，这将允许您始终向同一分区发送带有键X的消息。
更简单的方法是：以只处理您想要的消息的方式编写一个消费者。
-
有什么方法可以阻止Kafka的消费者在一段时间内消费信息吗？我希望消费者停止一段时间，然后开始消费最后一条未消费的消息。
-
由于它是一个Spring Boot应用程序，默认偏移量设置为Latest。我在这里做错了什么，请帮我弄明白。
-
我正在为Kafka0.9.0.0做Kafka快速入门。 我让zookeeper在监听，因为我运行了 只有一个代理在处侦听，因为我运行了 我有一个制作人在主题“测试”上发帖，因为我跑了 当我运行旧的API使用者时，它通过运行 但是，当我运行新的API使用者时，我在运行时没有得到任何东西 是否可以使用新的API从控制台使用者订阅主题？我该怎么修好它？
-
我有一个简单的Kafka设置。生成器正在以较高的速率向单个分区生成具有单个主题的消息。单个使用者正在使用来自此分区的消息。在此过程中，使用者可能会多次暂停处理消息。停顿可以持续几分钟。生产者停止产生消息后，所有排队的消息都将由使用者处理。生产者产生的消息似乎不会立即被消费者看到。我使用的是Kafka0.10.1.0。这里会发生什么？下面是使用消息的代码部分： 代理上的所有配置都保留为kafka默认
-
Avro对单个Kafka主题的信息进行编码，单个分区。这些消息中的每一条都只能由特定的消费者使用。对于ex，关于这个主题的消息a1、a2、b1和c1，有3个消费者，分别名为A、B和C，每个消费者将获得所有消息，但最终A将使用a1和a2、b1上的B和c1上的C。 我想知道当在Kafka上使用avro时，这是如何典型地解决的： 让使用者反序列化消息，然后由某个应用程序逻辑决定使用消息还是删除消息 使用
-
所以首先，为了能够暂停/停止消费者，我必须访问MessageListenerContainer。这意味着，在配置中，我将创建：ConcurrentKafkaListenerContainerFactory并（从2.2开始）使用它创建ConcurrentMessageListenerContainer的托管bean。然后可以使用这个bean来启动/停止消费者。管用。一旦它是并发的...我假设，我传递