class Fluent::Plugin::RdKafkaGroupInput::ForShutdown