Spring Kafka消费者线程池
我正在使用Spring Kafka消费者。我已将并发设置为10，并创建了5个消费者（用于5个主题）。所以有50个Spring Kafka消费者线程。
Kafka消费者可以使用的最大线程数是多少？如何增加此线程池的大小？我查阅了spring文档，但没有发现任何相关内容。
共有1个答案
没有限制；默认情况下，每个容器为线程使用一个SimpleAsynctaskeExecutor；没有涉及池。
-
我正在使用Spring Kafka consumer,它从主题中获取消息并将其保存到数据库中。如果满足故障条件，例如db不可用，kafka消费者库是否提供重试机制？如果是，是否有方法设置不同的重试间隔，如第1次重试应在5分钟后进行，第2次重试应在30分钟后进行，第3次重试应在1小时后进行等。
-
在使用Spring Kafka Consumer时，我有时会收到以下错误消息。如代码片段所示，我至少实现了一次语义 1）我的疑问是，我是否错过了来自消费者的任何信息？ 2） 我需要处理这个错误吗。由于 org.apache.kafka.clients.consumer.提交失败异常：无法完成偏移提交，因为消费者不是自动分区分配的活动组的一部分；消费者很可能被踢出组。 我的SpringKafka消费
-
我需要使用consume process Product模式来处理Kafka消息，并已使用Kafka事务管理器配置了Spring Kafka侦听器容器，还设置了事务id前缀以启用Kafka事务。我正在使用批处理的ack模式，并试图了解在这种模式下，在事务中何时提交偏移量。文档似乎表明，一旦使用了轮询中的所有记录，ack模式批提交偏移量——在事务上下文中也是这样吗，即每个轮询1个事务？ 或者，在使用
-
我在站点1（3个代理）有两个集群设置cluster-1，在站点2（3个代理）有两个集群设置cluster-2。使用spring kafka（1.3.6）消费者（一台机器）并通过@KafkaListener注释收听消息。我们如何为每个集群（c1和c2）实例化多个KafkaListenerContainerFactory，并同时监听来自这两个集群的数据。 我的侦听器应该同时使用来自这两个集群的消息。
-
我怎样才能暗示SpringKafka把每一个话题传播给一个不同的消费者呢？ 干杯
-
关于破坏者，我有以下问题： 消费者（事件处理器）没有实现他们实现EventHandler的任何可调用或可运行接口，那么他们如何能够并行运行，因此，例如，我有一个disruptor实现，其中有这样一个菱形模式 其中c1到c3可以在p1之后并联工作，C4和C5在p1之后工作。 所以通常我会有这样的东西（P1和C1-C5是可运行/可调用的） 但是在Disruptor的情况下，我的事件处理程序都没有实现R