Provide a way to support Consumer#enforceRebalance #3011
Description
Currently, we can use the RecordInterceptor to access the consumer and trigger an enforceRebalance. Explore an option to see if we can support this operation as a first-class citizen from the container. Fore more details: https://kafka.apache.org/36/javadoc/org/apache/kafka/clients/consumer/Consumer.html#enforceRebalance()