带断路器的Kafka消费者，使用弹性4J的重试模式

Question

我需要一些帮助来理解我如何能够提出一个解决方案使用Spring boot、Kafka、Resilence4J来实现来自我的Kafka消费者的微服务调用。假设微服务关闭了，那么我需要使用断路器模式通知我的Kafka消费者停止获取消息/事件，直到微服务启动并运行。

Answer 1

如果您使用的是Spring Kafka，则可以使用ConcurrentMessageListenerContainer类的Pause和Resume方法。您可以将EventListener附加到断路器，它侦听状态转换并暂停或恢复事件处理。将CircuitBreakerRegistry注入bean：

circuitBreakerRegistry.circuitBreaker("yourCBName").getEventPublisher().onStateTransition(
                        event -> {
                            switch (event.getStateTransition()) {
                                case CLOSED_TO_OPEN:
                                    container.pause();
                                case OPEN_TO_HALF_OPEN:
                                    container.resume();
                                case HALF_OPEN_TO_CLOSED:
                                    container.resume();
                                case HALF_OPEN_TO_OPEN:
                                    container.pause();
                                case CLOSED_TO_FORCED_OPEN:
                                    container.pause();
                                case FORCED_OPEN_TO_CLOSED:
                                    container.resume();
                                case FORCED_OPEN_TO_HALF_OPEN:
                                    container.resume();
                                default:
                            }
                        }
                );