Skip to content

Instantly share code, notes, and snippets.

@s-chb

s-chb/csv_ksqldb_connector

Last active July 1, 2020 10:28
Show Gist options

  • Select an option

    Learn more about clone URLs
  • Save s-chb/24a2e32c1b60e3aa915442b43394a87d to your computer and use it in GitHub Desktop.

Select an option

Learn more about clone URLs
Save s-chb/24a2e32c1b60e3aa915442b43394a87d to your computer and use it in GitHub Desktop.
Download ZIP
Raw
csv_ksqldb_connector
CREATE SOURCE CONNECTOR CSVSpoolDir WITH (
'connector.class' = 'com.github.jcustenborder.kafka.connect.spooldir.SpoolDirCsvSourceConnector',
'finished.path' = '/tmp/finished',
'input.path' = '/tmp/data',
'error.path' = '/tmp/error',
'input.file.pattern' = 'csv-spooldir-source.csv',
'topic' = 'spooldir-csv-topic',
'schema.generation.enabled' = 'true'
);
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment