class PulsarSdk::Client::Connection::ConsumerHandler