org.apache.storm.kafka

Class StaticPartitionConnections

java.lang.Object

org.apache.storm.kafka.StaticPartitionConnections

public class StaticPartitionConnections
extends Object

Constructor Summary

Constructors

Constructor and Description
StaticPartitionConnections(KafkaConfig conf)

Method Summary

Modifier and Type	Method and Description
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

Constructor Detail

StaticPartitionConnections

public StaticPartitionConnections(KafkaConfig conf)

Method Detail

getConsumer

public kafka.javaapi.consumer.SimpleConsumer getConsumer(int partition)

close

public void close()