presto-kafka/src/main/java/io/prestosql/plugin/kafka/KafkaRecordSetProvider.java/KafkaRecordSetProvider/KafkaRecordSetProvider
class KafkaRecordSetProvider:    @Inject
    public KafkaRecordSetProvider(DispatchingRowDecoderFactory decoderFactory, KafkaSimpleConsumerManager consumerManager)
    {
        this.decoderFactory = requireNonNull(decoderFactory, "decoderFactory is null");
        this.consumerManager = requireNonNull(consumerManager, "consumerManager is null");
    }