add a getTopicMetaData method in broker and expose it to producer 
------------------------------------------------------------------

                 Key: KAFKA-238
                 URL: https://issues.apache.org/jira/browse/KAFKA-238
             Project: Kafka
          Issue Type: Sub-task
          Components: core
            Reporter: Jun Rao


We need a way to propagate the leader and the partition information to the 
producer so that it can do load balancing and semantic partitioning. One way to 
do that is to have the producer get the information from ZK directly. This 
means that the producer needs to maintain a ZK session and has to subscribe to 
watchers, which can be complicated. An alternative approach is to have the 
following api on the broker.

TopicMetaData getTopicMetaData(String: topic)

TopicMetaData {
  Array[PartitionMetaData]: partitionsMetaData
}

PartitionMetaData {
  Int: partitionId
  String: leaderHostname
  Int: leaderPort
}

Using this api, the producer can get the metadata about a topic during initial 
startup or leadership change of a partition.

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: 
https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira

        

Reply via email to