How to transition a sink connector to a Strimzi kafka connect CR based one. #9848
Unanswered
piyushbhojgude
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
-
Hi, I currently have one kafka sink connector running, which was created using basic K8 deployment yamls along with config maps and all other resources. Now, I want to transition to using Strimzi Kafka connect CR.
How can I make this transition without any data loss?
I'm thinking of following plan:
Pause the existing connector.
Deploy the new Kafka connect cluster based on Strimzi Kafka Connect CR with the same group id and use existing topics for:
offset.storage.topic, config.storage.topic and status.storage.topic.
The only catch is I can't use the same connector name since Strimzi Kafka Connector CR doesn't allow strings with underscore.
My existing kafka connector name contains underscore. So I won't be able to reuse the existing name.
Once new setup is up and running delete the old connector and old kafka connect cluster.
Not sure of this is the right approach or if this would work as well.
Beta Was this translation helpful? Give feedback.
All reactions