-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathmm2.properties
More file actions
33 lines (26 loc) · 1.27 KB
/
mm2.properties
File metadata and controls
33 lines (26 loc) · 1.27 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
# MirrorMaker 2 (dedicated mode) — primary -> standby for commit-log
clusters = primary, standby
primary.bootstrap.servers = primary:9092
standby.bootstrap.servers = standby:9094
primary->standby.enabled = true
primary->standby.topics = commit-log
# Replication of __consumer_offsets is not needed for this exercise
primary->standby.sync.group.offsets.enabled = false
primary->standby.sync.topic.acls.enabled = false
primary->standby.emit.checkpoints.enabled = true
primary->standby.emit.heartbeats.enabled = true
# Critical for truncation detection: the source consumer must NOT silently jump
# forward when its offset falls outside [beginningOffset, endOffset]. With 'none',
# the consumer raises OffsetOutOfRangeException, which our patched MirrorSourceTask
# catches and triages into truncation (fail-fast) vs topic reset (re-seek to 0).
primary->standby.consumer.auto.offset.reset = none
# Single-broker test clusters
replication.factor = 1
checkpoints.topic.replication.factor = 1
heartbeats.topic.replication.factor = 1
offset-syncs.topic.replication.factor = 1
offset.storage.replication.factor = 1
status.storage.replication.factor = 1
config.storage.replication.factor = 1
# Faster topic discovery so reset recovery kicks in quickly during the test
refresh.topics.interval.seconds = 5