Make sure you have below containers running:
- createbuckets(Will be exited once the buckets are created)
- minio Which serves as a S3 layer for spark streaming
- spark-master
- spark-worker-1
- spark-worker-2
Run the Kstream example "basic" from home folder. This will load the data into the given topic.
./gradlew runStreams -Pargs=basic
Submit the command from current folder:
sh submit_to_container.sh
You can use below command to get into the spark container
docker-compose exec spark-master bash