Hi all,

I finally have a need to understand MirrorMaker well.  I’m running Kafka
0.8.2.2.  I see that my version of MirrorMaker has a —new.producer option,
which uses NewShinyProducer instead of OldProducer.

Without —new.producer, kafka-console-producer.sh seems to produce byte
messages that cause OldProducer to error with java.lang.ClassCastException:
[B cannot be cast to java.lang.String. So, it seems I should use
—new.producer, yes?  If so, are there other producer options I should be
aware of?

I have found
https://cwiki.apache.org/confluence/display/KAFKA/KIP-3+-+Mirror+Maker+Enhancement,
but that seems to be relevant to MirrorMaker in 0.9, correct?

Thanks!
-AO

Reply via email to