Circuit breaker implementation for Kafka Consumer

This solution is implemented using Resilience4j for circuit breaker. I have Kafka consumer implemented using spring-cloud-stream. Consumer code connects to external HTTP service( this can be any external/internal dependent service). When such service is down, you want to stop consuming messages from Queue/Topic. The Circuit Breaker is configured on this layer. As multiple messages start…