storm.kafka
Class StaticPartitionConnections
java.lang.Object
storm.kafka.StaticPartitionConnections
public class StaticPartitionConnections
- extends Object
Method Summary |
void |
close()
|
kafka.javaapi.consumer.SimpleConsumer |
getConsumer(int partition)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
StaticPartitionConnections
public StaticPartitionConnections(KafkaConfig conf)
getConsumer
public kafka.javaapi.consumer.SimpleConsumer getConsumer(int partition)
close
public void close()
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.