Escape special characters in KCQL


Question 

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/#

Answer 

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/#`
--
Last modified: April 24, 2024