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

        requireNonNull(kafkaConnectorConfig, "kafkaConfig is null");
        this.nodes = ImmutableSet.copyOf(kafkaConnectorConfig.getNodes());
    }