presto-kafka/src/main/java/io/prestosql/plugin/kafka/KafkaSimpleConsumerManager.java/KafkaSimpleConsumerManager/createConsumer
class KafkaSimpleConsumerManager:    private SimpleConsumer createConsumer(HostAddress host)
    {
        log.info("Creating new Consumer for %s", host);
        return new SimpleConsumer(host.getHostText(),
                host.getPort(),
                connectTimeoutMillis,
                bufferSizeBytes,
                "presto-kafka-" + nodeManager.getCurrentNode().getNodeIdentifier());
    }