MirrorMaker2 and cleanup.policy #9772
Unanswered
pablocavalieri
asked this question in
Q&A
Replies: 0 comments
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
I'm using
kafka.strimzi.io/v1beta2
KafkaMirrorMaker2
to migrate records from clustersource
to clustertarget
for some topics.source
cluster's topict
has cleanup policy set oncompact
but thetarget
cluster's topict
has a cleanup policy ofdelete
.I want mirror maker to copy the message for topic
t
fromsource
cluster totarget
cluster but not the cleanup policy.For context, what I'm doing is:
t
cleanup policy is set tocompact
target
cluster with the topic'st
cleanup policy set todelete
t
fromsource
totarget
target
' cluster's topict
usingkafka-delete-records --bootstrap-server <target's bootstrap server> --offset-json-file delete_records_config.json
where the fileoffset-json-file delete_records_config.json
sets the topic'st
partition'soffset
to-1
t
again fromsource
totarget
, topic'st
cleanup policy ontarget
is set tocompact
In both
source
andtarget
cluster theauto.create.topics.enable
property is set tofalse
Beta Was this translation helpful? Give feedback.
All reactions