between KAFKA 262 and 239 and 265
related to implementation of addPartitionTopicInfo
stemming from
private def addPartitionTopicInfo(topicDirs: ZKGroupTopicDirs,
partition: String,
topic: String, consumerThreadId:
String) {
and
private def addPartitionTopicInfo(currentTopicRegistry: Pool[String,
Pool[Partition, PartitionTopicInfo]],
topicDirs: ZKGroupTopicDirs,
partitionString: String,
once i finish the merge i will post where i am to a JIRA ticket and then
will start thinking about the issue and other can take a look too might
have better idea having touhced these tickets already
/*
Joe Stein
http://www.linkedin.com/in/charmalloc
Twitter: @allthingshadoop <http://www.twitter.com/allthingshadoop>
*/
