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:
- 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 ...