You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@kafka.apache.org by Joe Stein <cr...@gmail.com> on 2012/05/25 03:13:54 UTC

another ZookeeperConsumerConnector conflict

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>
*/