This example demonstrates how you can use Apache Camel Kafka component with Spring Boot.

It uses Spring Boot to send a kafka message every 5th second, and routes the message to a log.

The example can be built with

mvn clean install

The example can be built and run on local host:

The kafka brokers environment variable, "KAFKA_BROKERS" or Java system property should be set when running the example.

mvn -s configuration/settings.xml spring-boot:run -DKAFKA_BROKERS=kafka:9092

Optionally,The zipkin variables, "ZIPKIN_ENABLED", "ZIPKIN_ENDPOINT" or Java system property should be set when running the example.

mvn -s configuration/settings.xml spring-boot:run -DKAFKA_BROKERS=kafka:9092 -DZIPKIN_ENABLED=true -DZIPKIN_ENDPOINT=http://zipkinhost:9411/api/v2/spans

It is assumed that:

• OpenShift platform is already running, if not you can find details how to Install OpenShift at your site.
• Your system is configured for Fabric8 Maven Workflow, if not you can find a Get Started Guide

The example can be built and run on OpenShift using a single goal:

mvn -s configuration/settings.xml fabric8:deploy

When the example runs in OpenShift, you can use the OpenShift client tool to inspect the status

To list all the running pods:

oc get pods

Then find the name of the pod that runs this quickstart, and output the logs from the running pods with:

oc logs <name of pod>

You can also use the openshift web console to manage the running pods, and view logs and much more.