presto-kafka/src/main/java/io/prestosql/plugin/kafka/KafkaConnector.java/KafkaConnector/KafkaConnector
class KafkaConnector:    @Inject
    public KafkaConnector(
            LifeCycleManager lifeCycleManager,
            KafkaMetadata metadata,
            KafkaSplitManager splitManager,
            KafkaRecordSetProvider recordSetProvider)
    {
        this.lifeCycleManager = requireNonNull(lifeCycleManager, "lifeCycleManager is null");
        this.metadata = requireNonNull(metadata, "metadata is null");
        this.splitManager = requireNonNull(splitManager, "splitManager is null");
        this.recordSetProvider = requireNonNull(recordSetProvider, "recordSetProvider is null");
    }