soxueren / spring-streaming-with-kafka

gradle, docker-compose, spring-boot, spring-cloud-stream, kafka, @EnableBinding, Snk, Source, Processor

Streaming (spring spring-cloud-stream kafka)

Greater -> (messages) -> GreatingHandler -> (uppercased) -> Doubler -> (transformed) -> LogReceiver

gradle composeUp

gradle Greater:bootRun
gradle MessageReceiver:bootRun

gradle UpperCaser:bootRun
gradle Doubler:bootRun
gradle Logger:bootRun

gradle composeDown
gradle --stop

run all together for integration tests

gradle clean build

for testing run in order:

• kafka using docker-compose (read below)
• GreaterApplication
• UpperCaserApplication
• DoublerApplication
• LoggerApplication
• LogReceiverApplication (another logger)

kafka (docker):

# git clone https://github.com/wurstmeister/kafka-docker.git
# cd kafka-docker
# vim docker-compose-single-broker.yml # update 'host' and 'topics'
# docker-compose -f docker-compose-single-broker.yml up -d
gradle composeUp
gradle composeDown