Kafka Connect using file Source and Sink

Let's take a look at how to create topics using file Source and Sink, with the help of the following:

cd /opt/confluent-4.0.0/etc/kafkavi connect-file-test-source.propertiesname=local-file-sourceconnector.class=FileStreamSourcetasks.max=1file=/opt/kafka_2.10-0.10.2.1/source-file.txttopic=my-first-topicvi connect-file-test-sink.propertiesname=local-file-sinkconnector.class=FileStreamSinktasks.max=1file=/opt/kafka_2.10-0.10.2.1/target-file.txttopics=my-first-topic

Perform the following steps:

  1. Start the Source Connector and Sink Connector:
cd /opt/confluent-4.0.0$ ./bin/connect-standalone config/connect-standalone.properties config/connect-file-test-source.properties config/connect-file-test-sink.properties ...

Get Modern Big Data Processing with Hadoop now with the O’Reilly learning platform.

O’Reilly members experience books, live events, courses curated by job role, and more from O’Reilly and nearly 200 top publishers.