apache-kafkakafka-consumer-apiproject-reactorreactor-kafka

Does Reactor Kafka Consumer starts consuming again / starts rebalancing after Termination ( doOnTermimate invoked)

Does Reactor Kafka Consumer starts consuming again / starts rebalancing after Termination ( doOnTermimate)

Trying to come up with a Reactor Kafka Consumer Health Service. to know when the Consumer stops Consuming messages and not part of consumer group to rejoin again.

Solution

  • after termination

    You need a process supervisor to restart any terminated process. For example, a Kubernetes Pod restartPolicy

    starts rebalancing after Termination

    Yes, all Kafka consumer groups rebalance after terminating and restarting.

    This is not unique to Project Reactor.