Skip to content

How to run sample application

Abhishek Sharma edited this page Mar 8, 2014 · 16 revisions

Kafka-Message-Server is an sample application for demonstrating kafka usage as message-server. Please follow the below instructions for productive use of the sample application.

  1. Download Apache kafka version 0.8.0 zip file from kafka download page and extract it.

  2. There is no need to set hadoop or zookeper in your system. You can use zookeper startup script present in bin folder of Kafka.

  3. For the execution of the sample application - copy 'kafka-message-server-example-0.8.0.jar' in to the kafka folder where 'kafka_2.8.0-0.8.0.jar' is present.

  4. Copy following scripts from 'Kafka-Message-Server-Example/config' folder in to 'bin' folder of kafka

  • a) java-mail-content-producer.sh
  • b) java-mail-consumer-demo.sh
  • c) java-mail-producer-consumer-demo.sh
  • d) java-mail-producer-demo.sh

give execution permission to the scripts using chmod command.

  1. Copy 'commons-cli-1.1.jar' in to the Kafka 'libs' folder.

  2. Start Zookeper server using command - bin/zookeeper-server-start.sh config/zookeeper.properties

  3. Start Kafka server using command - bin/kafka-server-start.sh config/server.properties

  4. Start mail content creation program using command - bin/java-mail-content-producer.sh -path [directory-path]

  5. Start message server mail producer using command - bin/java-mail-producer-demo.sh -path [same directory path given above] -topic [topic name]

  6. Start message server mail consumer using command - bin/java-mail-consumer-demo.sh -topic [same topic name given above]

Clone this wiki locally