March 2018
Beginner to intermediate
394 pages
10h 57m
English
Streamed data from source file Demo-Source.txt is moved to destination file Demo-Sink.txt in distributed mode. If you want to run the previous example using distributed mode, you have to add the following parameter to source-file-stream and sink-file-stream in steps 3 and 4:
key.converter=org.apache.kafka.connect.json.JsonConverter key.converter.schemas.enable=true value.converter=org.apache.kafka.connect.json.JsonConverter value.converter.schemas.enable=true
Read now
Unlock full access