Configuration Properties Reference

A collection of all SRM specific configuration properties.

Table 1.
Property Default Value Description
sync.topic.configs.enabled true Enables the monitoring of the source cluster for configuration changes.
sync.topic.acls.enabled true Enables the monitoring of the source cluster for ACL changes.
emit.heartbeats.enabled true Enables periodic emission of heartbeats.
emit.heartbeats.interval.seconds 5 (seconds) The interval at which SRM emits heartbeats.
emit.checkpoints.enabled true Enables periodic emission of consumer offset information.
emit.checkpoints.interval.seconds 60 (seconds) The interval at which SRM emits checkpoint information.
refresh.topics.enabled true Enables a periodical check for new topics on source clusters.
refresh.topics.interval.seconds 10 (minutes) The interval at which SRM looks for new topics on source clusters.
refresh.groups.enabled true Enables a periodical check for new consumer groups on source clusters.
refresh.groups.interval.seconds 10 (minutes) The interval at which SRM looks for new consumer groups on source clusters.
replication.policy.class org.apache.kafka.connect.mirror.DefaultReplicationPolicy Replication policies to use. Use LegacyReplicationPolicy to mimic legacy MirrorMaker behavior.
heartbeats.topic.replication.factor 3 Replication factor used for internal heartbeat topics.
checkpoints.topic.replication.factor 3 Replication factor used for internal checkpoints topics.
offset-syncs.topic.replication.factor 3 Replication factor used for internal offset-syncs topics.