public class KafkaConsumer extends Object
KafkaConsumer(String zookeeperUrl, String groupId, String topic)
static void
main(String[] args)
void
start(int numOfConsumers)
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public KafkaConsumer(String zookeeperUrl, String groupId, String topic)
public static void main(String[] args)
public void start(int numOfConsumers)
Copyright © 2016 WSO2 Inc. All rights reserved.