Skip to content

Latest commit

 

History

History
44 lines (40 loc) · 2.52 KB

README.md

File metadata and controls

44 lines (40 loc) · 2.52 KB
Raw

Demo client app for sending and recieving messages using Apache Kafka

Usage

  1. Start a local instance of Kafka in Vagrant using the kafka machine
vagrant up kafka
  1. Provision the kafka machine using the kafka alias from the local ansible controller machine
vagrant up ansible
vagrant ssh
kafka
  1. Start the demo application
cd springboot-kafka-client
mvn clean install
java -jar target/springboot-kafka-client-1.0-SNAPSHOT.jar
  1. Sent a few messages to Kafka by using the configured http endpoint
http://localhost:8080/send

The logfile should contain information about the messages:

09:10:37.184 [kafka-producer-network-thread | tnt] INFO  se.sbab.kafka.spring.Sender - Sending message='{"timestamp": 1508829036647, "message": "Hello from TnTmessage' succeeded
09:10:37.255 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] INFO  se.sbab.kafka.spring.Receiver - received key='Key' message='{"timestamp":age": "Hello from TnT #1"}'
09:10:40.323 [kafka-producer-network-thread | tnt] INFO  se.sbab.kafka.spring.Sender - Sending message='{"timestamp": 1508829040315, "message": "Hello from TnTmessage' succeeded
09:10:40.324 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] INFO  se.sbab.kafka.spring.Receiver - received key='Key' message='{"timestamp":age": "Hello from TnT #2"}'
09:10:42.249 [kafka-producer-network-thread | tnt] INFO  se.sbab.kafka.spring.Sender - Sending message='{"timestamp": 1508829042246, "message": "Hello from TnTmessage' succeeded
09:10:42.250 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] INFO  se.sbab.kafka.spring.Receiver - received key='Key' message='{"timestamp":age": "Hello from TnT #3"}'
09:10:42.863 [kafka-producer-network-thread | tnt] INFO  se.sbab.kafka.spring.Sender - Sending message='{"timestamp": 1508829042859, "message": "Hello from TnTmessage' succeeded
09:10:42.864 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] INFO  se.sbab.kafka.spring.Receiver - received key='Key' message='{"timestamp":age": "Hello from TnT #4"}'

Configuration options

Modify the application.yml to use different Kafka servers: Local vagrant environment: bootstrap-servers: "d-kafka01.sbab.se:9092"

Sys environment: (servers from https://stash.sbab.se/projects/AFTO/repos/ansible/browse/inventories/sys/hosts [kafka] group) bootstrap-servers: "t-kafka01.sbab.se:9092,t-kafka02.sbab.se:9092,t-kafka03.sbab.se:9092"

Modify auto-offset-reset and group-id in application.yml file to change the consumer behaviour to meet your needs