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
Uh oh!
There was an error while loading. Please reload this page.
-
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