/kafka-producer-consumer-demo

kafka-producer-consumer-demo app

Primary LanguageJavaGNU General Public License v3.0GPL-3.0

#Kafka Demo application for producing and consuming topics

Starting Apache kafka locally:

  1. Untar the download

    #tar -xvf <kafka.tar>

  2. Build the project

    #./gradlew jar -PscalaVersion=

  3. Start zoopkeeper

    #bin/zookeeper config/zookeeper.properties

  4. Start broker Here I am creating 2 brokers (I have copied server.properties to 1 & 2)

    #bin/kafka-server-start.sh config/server1.properties

    #bin/kafka-server-start.sh config/server2.properties

  5. Creating topics

    #bin/kafka-topics.sh --create --bootstrap-server localhost:9093 --partitions=2 --replication-factor 2 --toipc

  6. Start spring boot application

    #mvn clean install -Ppersonal-repo -s