Subject: Running a stand alone Mirror Maker 2.0 cluster and Issues


Hmm  ( I did both )

another->another_test.enabled = true

another->another_test.topics = act_post

another->another_test.emit.heartbeats.enabled = false

another->another_test.consumer.auto.offset.reset = latest

another->another_test.sync.topic.acls.enabled = false

another.consumer.auto.offset.reset = latest

When I grep for the ConsumerConfig ( and there are 8 instances, this topic
has 4 partitions )
 [2019-10-17 14:01:21,879] INFO ConsumerConfig values:

allow.auto.create.topics = true

auto.commit.interval.ms = 5000

*auto.offset.reset* = earliest
I am now using the 2.4 branch from kafka trunk
https://github.com/apache/kafka/tree/2.4/connect/mirror
This code change works and makes sense.. I think all other settings will be
fine ( as can be overridden )  but for the 2 below..
*---
a/connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorConnectorConfig.java*

*+++
b/connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorConnectorConfig.java*

@@ -230,7 +230,7 @@ public class MirrorConnectorConfig extends
AbstractConfig {
props.keySet().retainAll(MirrorClientConfig.CLIENT_CONFIG_DEF.names());

         props.putAll(originalsWithPrefix(CONSUMER_CLIENT_PREFIX));

         props.put("enable.auto.commit", "false");

-        props.put("auto.offset.reset", "earliest");

+        props.put("auto.offset.reset", "latest");

         return props;

     }
Regards.

On Wed, Oct 16, 2019 at 3:36 PM Ryanne Dolan <[EMAIL PROTECTED]> wrote: