Skip to content

Instantly share code, notes, and snippets.

@s-chb

s-chb/json_ksqldb_connector

Created July 1, 2020 09:55
Show Gist options
  • Save s-chb/3d3d1fe728b52eadb3fa79c68e3223a6 to your computer and use it in GitHub Desktop.
Save s-chb/3d3d1fe728b52eadb3fa79c68e3223a6 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
json_ksqldb_connector
CREATE SOURCE CONNECTOR JsonSpoolDir WITH (
'tasks.max' = '1',
'connector.class' = 'com.github.jcustenborder.kafka.connect.spooldir.SpoolDirJsonSourceConnector',
'input.path' = '/tmp/data',
'input.file.pattern' = 'json-spooldir-source.json',
'error.path' = '/tmp/error',
'finished.path' = '/tmp/finished',
'halt.on.error' = 'false',
'topic' = 'spooldir-json-topic',
'schema.generation.enabled' = 'true'
);
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment