Latest version: 4.1.x
Escape special characters in KCQL
How can I escape special characters in KCQL when creating a connector
Example MQTT Source Connector with wildcard # in topic’s name
kcql=INSERT INTO myKafkaTopic SELECT * FROM /some/path/#
Escaping special character in KCQL is done by enclosing the statement in backticks `
In the above example we need to enclose the whole path in backticks.
kcql=INSERT INTO myKafkaTopic SELECT * FROM `/some/path/#`