Consumer groups to replicate. Supports comma-separated group IDs and regexes.
| Type: | list |
|---|---|
| Default: | .* |
| Valid Values: | |
| Importance: | high |
Exclude groups. Supports comma-separated group IDs and regexes. Excludes take precedence over includes.
| Type: | list |
|---|---|
| Default: | console-consumer-.*,connect-.*,__.* |
| Valid Values: | |
| Importance: | high |
Replication factor for checkpoints topic.
| Type: | short |
|---|---|
| Default: | 3 |
| Valid Values: | |
| Importance: | low |
Timeout when polling source cluster.
| Type: | long |
|---|---|
| Default: | 1000 (1 second) |
| Valid Values: | |
| Importance: | low |
Whether to replicate consumer offsets to target cluster.
| Type: | boolean |
|---|---|
| Default: | true |
| Valid Values: | |
| Importance: | low |
Frequency of checkpoints.
| Type: | long |
|---|---|
| Default: | 60 |
| Valid Values: | |
| Importance: | low |
GroupFilter to use. Selects consumer groups to replicate.
| Type: | class |
|---|---|
| Default: | org.apache.kafka.connect.mirror.DefaultGroupFilter |
| Valid Values: | |
| Importance: | low |
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 |
The location (source/target) of the offset-syncs topic.
| Type: | string |
|---|---|
| Default: | source |
| Valid Values: | [source, target] |
| Importance: | low |
Whether to periodically check for new consumer groups.
| Type: | boolean |
|---|---|
| Default: | true |
| Valid Values: | |
| Importance: | low |
Frequency of group refresh.
| Type: | long |
|---|---|
| Default: | 600 |
| Valid Values: | |
| Importance: | low |
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 |
Frequency of consumer group offset sync.
| Type: | long |
|---|---|
| Default: | 60 |
| Valid Values: | |
| Importance: | low |
TopicFilter to use. Selects topics to replicate.
| Type: | class |
|---|---|
| Default: | org.apache.kafka.connect.mirror.DefaultTopicFilter |
| Valid Values: | |
| Importance: | low |