Spring Kafka消费者Client-Id配置
我有两个Kafka监听器组件，每个组件监听不同的主题并期待不同的有效负载。我的问题是，我可以对两者使用相同的客户端id吗？还是必须使用不同的客户端id？如果客户端id必须不同，我想了解一个可以有效使用客户端id的用例。
共有1个答案
根据文档：
发出请求时传递给服务器的id字符串。这样做的目的是，通过允许在服务器端请求日志中包含一个逻辑应用程序名称，能够跟踪请求的来源，而不仅仅是IP/端口。
因此，从技术上讲，您确实可以为不同的消费者/生产者提供相同的价值。
-
我正在使用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，并同时监听来自这两个集群的数据。 我的侦听器应该同时使用来自这两个集群的消息。
-
我重新安装了Apache Kafka 0.10.1.0。 在使用Producer/Consumer Java示例时，我无法知道Consumer示例中的group.id参数。 让我知道如何解决这个问题。 下面是我使用的消费者示例： 在为consumer运行命令后，我可以看到Producer发布的消息（在控制台上）。但无法看到来自java程序的消息 bin\windows\kafka-console-
-
我怎样才能暗示SpringKafka把每一个话题传播给一个不同的消费者呢？ 干杯