Kafka消费断路器
有没有一种方法实现一个断路器模式与SpringKafka为基础的消费者。我想知道，在实现我的Spring kafka consumer时，如果基于某个外部系统的数据处理失败并引发网络错误，是否可以停止使用记录。但是，如果解决了网络问题，消费者应该再次正常处理。
共有1个答案
如果希望在下游服务或DB关闭时停止使用消息，可以参考此解决方案。
示例
- 使用者正在呼叫服务A
- 服务A正在调用外部HTTP服务B
- 要在外部服务B关闭时设置断路器
https://dublincoders.com/circuit-breaker-kafka/
-
我正在尝试实现Spring kafka消费者，它需要在处理事件时出现某个异常后暂停（例如：在将事件信息存储到DB时，DB已关闭）。 我们如何在spring boot-2.3.8（spring kafka）中使用Resilience4j断路器方法来处理这种情况 寻找一些消费者暂停和恢复的例子。 在Kafka，listerner只是想捕捉解析错误。如果出现5个以上的解析错误，则需要停止侦听器。但我不确
-
我刚接触Kafka，很少阅读教程。我无法理解使用者和分区之间的关系。 请回答我下面的问题。 > 消费者是否由ZK分配到单个分区，如果是，如果生产者将消息发送到不同的分区，那么其他分区的消费者将如何使用该消息？ 我有一个主题，它有3个分区。我发布消息，它会转到P0。我有5个消费者（不同的消费者群体）。所有消费者都会阅读P0的信息吗？若我增加了许多消费者，他们会从相同的P0中阅读信息吗？如果所有消费者
-
我有一个简单的Kafka设置。生成器正在以较高的速率向单个分区生成具有单个主题的消息。单个使用者正在使用来自此分区的消息。在此过程中，使用者可能会多次暂停处理消息。停顿可以持续几分钟。生产者停止产生消息后，所有排队的消息都将由使用者处理。生产者产生的消息似乎不会立即被消费者看到。我使用的是Kafka0.10.1.0。这里会发生什么？下面是使用消息的代码部分： 代理上的所有配置都保留为kafka默认
-
Flink kafka消费者有两种类型的消费者，例如： 这两个消费者层次结构扩展了相同的类。我想知道维护编号类背后的设计决策是什么？我们什么时候应该使用其中一种？ 我注意到带有数字后缀的类有更多的特性（例如ratelimiting）。 https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-kafka
-
我需要一些帮助来理解我如何能够提出一个解决方案使用Spring boot、Kafka、Resilence4J来实现来自我的Kafka消费者的微服务调用。假设微服务关闭了，那么我需要使用断路器模式通知我的Kafka消费者停止获取消息/事件，直到微服务启动并运行。
-
我的Kafka集群有下一个配置。 Kafka版本集群(V1.1.0)3个代理 一个主题（“FARA”），包含5个分区和3个副本 每个分区中有10000000条消息。总共50.000.0000 我使用的是Kafka-Consumer-Perf，测试用的是下面使用ConsumerPerformance的decro。 null 我定期运行下面的命令 ./kafka-run-class.sh kafka.