Multiple consumer groups bug fix

mjhubert · mjhubert · commit 2fdff7996a4c · 2015-12-29T08:10:31.000+01:00
diff --git a/src/Kafka/Kafka.Client/Utils/ZkUtils.cs b/src/Kafka/Kafka.Client/Utils/ZkUtils.cs
@@ -601,7 +601,7 @@ public string ConsumerRegistryDir
         {
             get
             {
-                return this.ConsumerDir + "/ids";
+                return this.ConsumerGroupDir + "/ids";
             }
         }
     }

Original file line number	Diff line number	Diff line change
`@@ -601,7 +601,7 @@ public string ConsumerRegistryDir`
`601`	`601`	`{`
`602`	`602`	`get`
`603`	`603`	`{`
`604`		`- return this.ConsumerDir + "/ids";`
	`604`	`+ return this.ConsumerGroupDir + "/ids";`
`605`	`605`	`}`
`606`	`606`	`}`
`607`	`607`	`}`