Re: reassign __consumer_offsets partitions

2015-12-18 Thread Damian Guy
And in doing so i've answered my own question ( i think! ) - i don't believe the topic has been created on that cluster yet... On 18 December 2015 at 10:56, Damian Guy wrote: > I was just trying to get it generate the json for reassignment and the > output was empty, i.e., > > offsets.json > ===

Re: reassign __consumer_offsets partitions

2015-12-18 Thread Damian Guy
I was just trying to get it generate the json for reassignment and the output was empty, i.e., offsets.json = {"topics": [ {"topic": "__consumer_offsets"} ], "version":1 } bin/kafka-reassign-partitions.sh --zookeeper blah --topics-to-move-json-file ~/offsets.json

Re: reassign __consumer_offsets partitions

2015-12-17 Thread Ben Stopford
Hi Damian The reassignment should treat the offsets topic as any other topic. I did a quick test and it seemed to work for me. Do you see anything suspicious in the controller log? B > On 16 Dec 2015, at 14:51, Damian Guy wrote: > > Hi, > > > We have had some temporary nodes in our kafka cl

reassign __consumer_offsets partitions

2015-12-16 Thread Damian Guy
Hi, We have had some temporary nodes in our kafka cluster and i now need to move assigned partitions off of those nodes onto the permanent members. I'm familiar with the kafka-reassign-partitions script, but ... How do i get it to work with the __consumer_offsets partition? It currently seems to