Chapter 4. Camel Kafka Connector

Camel Kafka Connector is available as a Technology Preview feature in Red Hat Integration 2020-Q2. Using Camel Kafka Connector, you can configure standard Camel components as connectors in Kafka Connect. This widens the scope of possible integrations beyond the external systems supported by Kafka Connect alone.

Camel Kafka Connector provides a user-friendly way to configure Camel components directly in the Kafka Connect framework. You can leverage Camel components for integration with different systems by connecting to or from Camel Kafka sink or source connectors. You do not need to write any code, and can include the appropriate connector JARs in your Kafka Connect image and configure the connector options using custom resources.

Camel Kafka Connector is built on Apache Camel Kafka Connector, which is a subproject of the Apache Camel open source community. Camel Kafka Connector is fully integrated with OpenShift Container Platform, AMQ Streams, and Kafka Connect. Camel Kafka Connector is available with the Red Hat Integration - Camel K distribution for cloud-native integration on OpenShift.

Important

Technology Preview features are not supported with Red Hat production service-level agreements (SLAs) and might not be functionally complete. Red Hat does not recommend implementing any Technology Preview features in production environments.

This Technology Preview feature provides early access to upcoming product innovations, enabling you to test functionality and provide feedback during the development process. For more information about support scope, see Technology Preview Features Support Scope.

4.1. Camel Kafka Connector features

The Camel Kafka Connector Technology Preview includes the following main features:

  • OpenShift Container Platform 4.4 or 4.3
  • AMQ Streams 1.5
  • Kafka Connect 2.5
  • Camel 3.1
  • Selected Camel Kafka connectors

4.2. Available Camel Kafka connectors

Table 4.1. Camel Kafka connectors in Technology Preview

ConnectorSink/source

Amazon AWS Kinesis

Sink and source

Amazon AWS S3

Sink and source

Cassandra Query Language (CQL)

Sink only

Elasticsearch

Sink only

Java Message Service (JMS)

Sink and source

Salesforce

Source only

Syslog

Source only

Additional resources