Table of Contents

1. Challenge

   Create a Connector to Export Data from the `inventory_purchases` Topic to a File

   1. Create a FileStreamSinkConnector:

   curl -X POST http://localhost:8083/connectors -H "Content-Type: application/json" -d '{
     "name": "file_sink",
     "config": {
       "connector.class": "org.apache.kafka.connect.file.FileStreamSinkConnector",
       "tasks.max": "1",
       "file": "/home/cloud_user/output/output.txt",
       "topics": "inventory_purchases",
       "key.converter": "org.apache.kafka.connect.storage.StringConverter",
       "value.converter": "org.apache.kafka.connect.storage.StringConverter"
     }
   }'
   

   1. We should see data from the topic appearing in the output file:

   cat /home/cloud_user/output/output.txt
   

2. Challenge

   Publish a New Purchase of Plums to the `inventory_purchases` Topic

   1. Start up a console producer:

   kafka-console-producer --broker-list localhost:9092 --topic inventory_purchases
   

   1. Publish some data representing a purchase of plums:

   plums:5
   

   1. Check the file and verify that the purchase of plums shows up in the file data:

   cat /home/cloud_user/output/output.txt
   

   Note: It may take a few moments for the connector to process the new data.