-
json-serailizers - these are Kafka Serializers and De-serializers which convert the domain object to json and back
-
sample-raw-producer - to dispatch new "Work" units to a "workunits" kafka topic
-
sample-raw-consumer - to consume the available "Work" units from the "workunits" kafka topic
Assuming you are in the Kafka home folder, you can use the following set of commands to start a local kafka cluster
cd sample-raw-producer
../gradlew bootRun
cd sample-raw-consumer
../gradlew bootRun
The producer should print a message on the console that the Work unit has been dispatched and the consumer should receive and process the Work unit