Re: Kafka MirrorMaker - not replicating messages after being brought up

2017-06-21 Thread Richard Shaw
Karan, have you got auto.offset.reset in your consumer.properties? https://kafka.apache.org/documentation/#newconsumerconfigs On Thu, Jun 22, 2017 at 2:00 AM, karan alang wrote: > Hi All, > > I've 2 Kafka clusters (Kafka 10) & I'm trying to test the MirrorMaker > functionality. > > Here is what

JMX security options resulting in log4j issue

2017-06-20 Thread Richard Shaw
Hi, I want to enable security for JMX but I'm hitting a broker startup issue which I can't quite work out and wonder if anyone has any ideas. $ export KAFKA_JMX_OPTS="-Dcom.sun.management.jmxremote \ -Dcom.sun.management.jmxremote.port=12346 \ -Dcom.sun.management.jmxremote.rmi.port=12346 \ -Dcom