blob: f439cde6c9c5455873215a4e86df73f16621fed8 [file] [log] [blame]
= Camel Kafka example
=== Introduction
An example which shows how to integrate Camel with Kafka.
This project consists of the following examples:
1. Send messages continuously by typing on the command line.
2. Example of partitioner for a given producer.
3. Topic is sent in the header as well as in the URL.
=== Preparing Kafka
This example requires that Kafka Server is up and running.
$ ${KAFKA}/bin/ ${KAFKA}/config/
$ ${KAFKA}/bin/ ${KAFKA}/config/
You will need to create following topics before you run the examples.
On windows run
$ ${KAFKA}/bin/kafka-topics.bat --create --zookeeper <zookeeper host ip>:<port> --replication-factor 1 --partitions 2 --topic TestLog
$ ${KAFKA}/bin/kafka-topics.bat --create --zookeeper <zookeeper host ip>:<port> --replication-factor 1 --partitions 1 --topic AccessLog
On linux run
$ ${KAFKA}/bin/ --create --zookeeper <zookeeper host ip>:<port> --replication-factor 1 --partitions 2 --topic TestLog
$ ${KAFKA}/bin/ --create --zookeeper <zookeeper host ip>:<port> --replication-factor 1 --partitions 1 --topic AccessLog
=== Build
You will need to compile this example first:
$ mvn compile
=== Run
Run the consumer first in separate shell
$ mvn compile exec:java -Pkafka-consumer
Run the message producer in the seperate shell
$ mvn compile exec:java -Pkafka-producer
Initially, some messages are sent programmatically.
On the command prompt, type the messages. Each line is sent as one message to kafka
Press `Ctrl-C` to exit.
=== Configuration
You can configure the details in the file:
You can enable verbose logging by adjusting the `src/main/resources/`
file as documented in the file.
=== Forum, Help, etc
If you hit an problems please let us know on the Camel Forums
Please help us make Apache Camel better - we appreciate any feedback you may
have. Enjoy!
The Camel riders!