SpringKafka-所有主题进入同一消费者
我怎样才能暗示SpringKafka把每一个话题传播给一个不同的消费者呢？
干杯
共有1个答案
对每个使用者使用不同的GroupID。由于您的所有3个消费者都在同一个组中，他们将根据一个主题在自己之间划分分区。因为每个主题都有一个分区，所以只有一个使用者可以分配它。
也不要在订阅调用中包含每个主题，只包含您希望在每个消费者中包含的主题。
在KAFKAs网站上阅读更多内容。他们把这件事说得很清楚。
-
我有一个spring boot项目，我是spring-kafka来连接底层的kafka事件枢纽。 我不得不在同一节消费者课上听2个不同的话题。我有两种方法可以这样做。 一个是要有两个这样的Kafka听众： 另一种方法是在同一个kafkaListener中有两个主题，如下所示 ===================edit===============application.yml中的Kafka属性
-
我正在使用Spring Kafka consumer,它从主题中获取消息并将其保存到数据库中。如果满足故障条件，例如db不可用，kafka消费者库是否提供重试机制？如果是，是否有方法设置不同的重试间隔，如第1次重试应在5分钟后进行，第2次重试应在30分钟后进行，第3次重试应在1小时后进行等。
-
在使用Spring Kafka Consumer时，我有时会收到以下错误消息。如代码片段所示，我至少实现了一次语义 1）我的疑问是，我是否错过了来自消费者的任何信息？ 2） 我需要处理这个错误吗。由于 org.apache.kafka.clients.consumer.提交失败异常：无法完成偏移提交，因为消费者不是自动分区分配的活动组的一部分；消费者很可能被踢出组。 我的SpringKafka消费
-
我必须记录消费者在SpringKafka中花费的时间。由于kafkaListener方法对每条消息都执行，因此在那里放置一个记录器是行不通的。此外，有时一些信息会丢失，而不是被消费者消费掉。我应该把记录器放在哪里，以找出消费者启动后的弹性时间。使用者不会退出或关闭，其轮询将无限期进行
-
我有@KafkaListener使用topicPattern与正则表达式，工作正常（foo。*），但现在我想将侦听器分配给所有匹配主题的所有分区。 https://docs.spring.io/spring-kafka/docs/2.6.1/reference/html/#tip-assign-all-parts并没有真正帮助我，因为我不知道主题名称。
-
我需要使用consume process Product模式来处理Kafka消息，并已使用Kafka事务管理器配置了Spring Kafka侦听器容器，还设置了事务id前缀以启用Kafka事务。我正在使用批处理的ack模式，并试图了解在这种模式下，在事务中何时提交偏移量。文档似乎表明，一旦使用了轮询中的所有记录，ack模式批提交偏移量——在事务上下文中也是这样吗，即每个轮询1个事务？ 或者，在使用