• groups

    Consumer groups to replicate. Supports comma-separated group IDs and regexes.

    Type:list
    Default:.*
    Valid Values:
    Importance:high
  • groups.exclude

    Exclude groups. Supports comma-separated group IDs and regexes. Excludes take precedence over includes.

    Type:list
    Default:console-consumer-.*,connect-.*,__.*
    Valid Values:
    Importance:high
  • checkpoints.topic.replication.factor

    Replication factor for checkpoints topic.

    Type:short
    Default:3
    Valid Values:
    Importance:low
  • consumer.poll.timeout.ms

    Timeout when polling source cluster.

    Type:long
    Default:1000 (1 second)
    Valid Values:
    Importance:low
  • emit.checkpoints.enabled

    Whether to replicate consumer offsets to target cluster.

    Type:boolean
    Default:true
    Valid Values:
    Importance:low
  • emit.checkpoints.interval.seconds

    Frequency of checkpoints.

    Type:long
    Default:60
    Valid Values:
    Importance:low
  • group.filter.class

    GroupFilter to use. Selects consumer groups to replicate.

    Type:class
    Default:org.apache.kafka.connect.mirror.DefaultGroupFilter
    Valid Values:
    Importance:low
  • metric.names.formats

    Deprecated. The formats in which metrics are emitted. Valid values are legacy and new. When set to legacy, the metrics have the following name "kafka.connect.mirror:type=MirrorCheckpointConnector,source={SOURCE},target={TARGET},group={GROUP},topic={TOPIC},partition={PARTITION}". When set to new, the metrics have the following name "kafka.connect:type=plugins,connector={CONNECTOR},task={TASK},source={SOURCE},target={TARGET},group={GROUP},topic={TOPIC},partition={PARTITION}". When set to "legacy,new" the connector will emit metrics with both names, this can be useful when migrating to the new format but it doubles the amount of metrics that are emitted.
    In Kafka 5.0 the legacy format and this configuration will be removed and the metrics will always use the new names.

    Type:list
    Default:legacy
    Valid Values:[legacy, new]
    Importance:low
  • offset-syncs.topic.location

    The location (source/target) of the offset-syncs topic.

    Type:string
    Default:source
    Valid Values:[source, target]
    Importance:low
  • refresh.groups.enabled

    Whether to periodically check for new consumer groups.

    Type:boolean
    Default:true
    Valid Values:
    Importance:low
  • refresh.groups.interval.seconds

    Frequency of group refresh.

    Type:long
    Default:600
    Valid Values:
    Importance:low
  • sync.group.offsets.enabled

    Whether to periodically write the translated offsets to __consumer_offsets topic in target cluster, as long as no active consumers in that group are connected to the target cluster

    Type:boolean
    Default:false
    Valid Values:
    Importance:low
  • sync.group.offsets.interval.seconds

    Frequency of consumer group offset sync.

    Type:long
    Default:60
    Valid Values:
    Importance:low
  • topic.filter.class

    TopicFilter to use. Selects topics to replicate.

    Type:class
    Default:org.apache.kafka.connect.mirror.DefaultTopicFilter
    Valid Values:
    Importance:low