#Java - Code Snippets for '#Org.apache.storm.kafka.trident.GlobalPartitionInformation'

#Java - Code Snippets for '#Org.apache.storm.kafka.trident.GlobalPartitionInformation' - 1 code snippet(s) found

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

    public static GlobalPartitionInformation buildPartitionInfo(int numPartitions, int brokerPort) {

        GlobalPartitionInformation globalPartitionInformation = new GlobalPartitionInformation(TOPIC);

        for (int i = 0; i < numPartitions; i++) {

            globalPartitionInformation.addPartition(i, Broker.fromString("broker-" + i + " :" + brokerPort));

        }

        return globalPartitionInformation;

    }

_{Like Feedback org.apache.storm.kafka.trident.GlobalPartitionInformation}

Search Java Code Snippets