Search code examples
apache-kafkaapache-kafka-connectksqldb

How can I alter a connector with ksqldb once it has been already created?


Once I have a connector created by using the ksqldb expression CREATE SOURCE CONNECTOR..., how can I make changes with ksqldb? Is there a way to alter the initial definition? Something like ALTER CONNECTOR...? If not, what is the proper way to handle changes in connectors with ksqldb?


Solution

  • Kafka Connect is stateless, so it's safe to run DROP + CREATE CONNECTOR with new config