How to do graceful shutdown in reactive kafka consumer?

[architmmmec]

How to do graceful shutdown in reactive kafka consumer?

[simonbasle]

As far as I can see, the KafkaReceiver automatically closes the underlying kafka Consumer: the ConsumerHandler close() stops the ConsumerEventLoop which triggers a CloseEvent that shuts down the kafka Consumer here: https://github.com/reactor/reactor-kafka/blob/master/src/main/java/reactor/kafka/receiver/internals/ConsumerEventLoop.java#L371