From ff4f10bee729c84068a12a8e7eb2bb151bafa1d5 Mon Sep 17 00:00:00 2001 From: Selim Horri Date: Tue, 17 Aug 2021 09:01:35 +0100 Subject: [PATCH 1/2] create README file --- README.md | 43 +++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 43 insertions(+) create mode 100644 README.md diff --git a/README.md b/README.md new file mode 100644 index 0000000..8c60c4e --- /dev/null +++ b/README.md @@ -0,0 +1,43 @@ +# KafkaBoot +## 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} + +
+ _   __         __  _           ______                _   
+| | / /        / _|| |          | ___ \              | |  
+| |/ /   __ _ | |_ | | __  __ _ | |_/ /  ___    ___  | |_ 
+|    \  / _` ||  _|| |/ / / _` || ___ \ / _ \  / _ \ | __|
+| |\  \| (_| || |  |   < | (_| || |_/ /| (_) || (_) || |_ 
+\_| \_/ \__,_||_|  |_|\_\ \__,_|\____/  \___/  \___/  \__|
+Supersonic Java with Spring Boot ☕️💚
+
+ +### Kafka producer + +- Launch Zookeeper server + +```shell + ${KAFKA_HOME}/bin/zookeeper-server-start.sh ./config/zookeeper.properties +``` + +- Launch Kafka server + +```shell + ${KAFKA_HOME}/bin/kafka-server-start.sh ./config/server.properties +``` + +- Create new Topic called 'NewTopic' + +```shell + ${KAFKA_HOME}/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic NewTopic --from-beginning +``` + +### Kafka consumer (optional) + +- Launch a consumer message streamer + +```shell + ${KAFKA_HOME}/bin/kafka-console-producer --broker-list localhost:9092 --topic NewTopic +``` From 8016540fa3f1cc9683f93d2ee52c92a274b68cf7 Mon Sep 17 00:00:00 2001 From: Selim Horri Date: Tue, 17 Aug 2021 09:03:45 +0100 Subject: [PATCH 2/2] rectify project title --- README.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/README.md b/README.md index 8c60c4e..9d1c2e3 100644 --- a/README.md +++ b/README.md @@ -1,4 +1,4 @@ -# KafkaBoot +# 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: