|
Spring Integration Kafka Support | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface ConnectionFactory
Creates Kafka connections and retrieves metadata for topics and partitions.
Method Summary | |
---|---|
Connection |
connect(BrokerAddress brokerAddress)
Create a connection to a Kafka broker, caching it internally |
BrokerAddress |
getLeader(Partition partition)
Return the leader for a single partition |
java.util.Map<Partition,BrokerAddress> |
getLeaders(java.lang.Iterable<Partition> partitions)
Retrieve the leaders for a set of partitions. |
java.util.Collection<Partition> |
getPartitions(java.lang.String topic)
Retrieves the partitions of a given topic |
void |
refreshMetadata(java.util.Collection<java.lang.String> topics)
Refresh the cached metadata (i.e. |
Method Detail |
---|
Connection connect(BrokerAddress brokerAddress)
brokerAddress
- a broker address
java.util.Map<Partition,BrokerAddress> getLeaders(java.lang.Iterable<Partition> partitions)
partitions
- whose leaders are queried
BrokerAddress getLeader(Partition partition)
partition
- the partition whose leader is queried
void refreshMetadata(java.util.Collection<java.lang.String> topics)
topics
- the topics for which to refresh the leadersjava.util.Collection<Partition> getPartitions(java.lang.String topic)
topic
- the topic to query for
|
Spring Integration Kafka Support | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |