Download the 2.2.0 release and un-tar it: http://ftp.unicamp.br/pub/apache/kafka/2.2.0/kafka_2.12-2.2.0.tgz

tar -xzf kafka_2.12-2.2.0.tgz
cd kafka_2.12-2.2.0

start the Kafka server:

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

Lets create a topic named "test" with a single partition and only one replica

bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test

Send some messages

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
> message 1
> message 2

Clone this repository into another folder git clone https://github.com/gabryelrock/poc-springboot-camel-kafka.git

Start the application typing it on the terminal gradle bootRun

Back to the terminal where the step 4 was done and send some messages again like "apple", "orange" or "limon", now on the terminal where the application was started (step 6) you'll see what predicate and processor was actived, for example, when you sent apple, Apple predicate will process the message and print something. :)