Hi everyone, I am using MirrorMaker to consume from a 0.8.2.2 cluster and produce to a 0.10.2 cluster. All the topics have two partitions on both clusters. My consumer.properties is:
zookeeper.connect=[string of servers] group.id=MirrorMaker num.consumer.fetchers=2 partition.assignment.strategy=roundrobin My producer.properties is: metadata.broker.list=[string of servers] compression.codec=gzip producer.type=async message.send.max.retries=2 My understanding from the documentation is that this *should* work, but it is not. All my data is going into partition 1 on the target cluster for all topics. Can someone help me understand what I'm missing here? Thank you for your time! Chris