kafka-boot

kafka-producer-consumer-with-spring-boot

Simple Spring Boot app to consume the published message into a Kafka topic through a simple Rest API: /messages/publish/{msg}

Kafka producer

• Launch Zookeeper server

  ${KAFKA_HOME}/bin/zookeeper-server-start.sh ${KAFKA_HOME}/config/zookeeper.properties

• Launch Kafka server

  ${KAFKA_HOME}/bin/kafka-server-start.sh ${KAFKA_HOME}/config/server.properties

• Create new Topic called 'NewTopic'

  ${KAFKA_HOME}/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic NewTopic --from-beginning

Kafka consumer (optional)

• Launch a consumer message streamer

  ${KAFKA_HOME}/bin/kafka-console-producer --broker-list localhost:9092 --topic NewTopic