class Fluent::KafkaGroupInput::ForShutdown