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
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