#Java - Code Snippets for '#Storm.kafka.ZkHosts'

#Java - Code Snippets for '#Storm.kafka.ZkHosts' - 1 code snippet(s) found

Sample 1. Code Sample / Example / Snippet of org.apache.storm.kafka.ZkHosts

    private TransactionalTridentKafkaSpout createKafkaSpout() {

        ZkHosts hosts = new ZkHosts(zkUrl);

        TridentKafkaConfig config = new TridentKafkaConfig(hosts, "test");

        config.scheme = new SchemeAsMultiScheme(new StringScheme());



        config.startOffsetTime = kafka.api.OffsetRequest.LatestTime();

        return new TransactionalTridentKafkaSpout(config);

    }

_{Like Feedback org.apache.storm.kafka.ZkHosts}

Search Java Code Snippets