第4章 Camel Kafka Connector リリースノート

Camel Kafka Connector は、Red Hat Integration 2020-Q4 ではテクノロジープレビューのコンポーネントとして使用できます。Camel Kafka Connector を使用すると、Kafka Connect で標準の Camel コンポーネントをコネクターとして設定できます。これにより、可能なインテグレーションの範囲が、Kafka Connect のみによってサポートされる外部システム以外にも広がります。

Camel Kafka Connector を使用すると、Kafka Connect フレームワークで Camel コンポーネントを直接設定するのがより簡単になります。Camel Kafka シンクまたはソースコネクターを接続元または接続先とすることで、Camel コンポーネントを利用して異なるシステムとの統合を行うことができます。コードを作成する必要はありません。また、適切なコネクター JAR を Kafka Connect イメージに含めることができ、カスタムリソースを使用してコネクターオプションを設定できます。

Camel Kafka Connector は、Apache Camel オープンソースコミュニティーのサブプロジェクトである Apache Camel Kafka Connector 上に構築されます。Camel Kafka Connector は、OpenShift Container Platform、AMQ Streams、および Kafka Connect と完全に統合されています。OpenShift 上のクラウドネイティブインテグレーションでは、Red Hat Integration - Camel K ディストリビューションにて Camel Kafka Connector を利用できます。

重要

テクノロジープレビューの機能は、Red Hat の本番環境のサービスレベルアグリーメント (SLA) ではサポートされず、機能的に完全ではないことがあります。Red Hat は、本番環境でのテクノロジープレビュー機能の実装は推奨しません。

テクノロジープレビューの機能は、最新の技術をいち早く提供して、開発段階で機能のテストやフィードバックの収集を可能にするために提供されます。サポート範囲の詳細は、「テクノロジプレビュー機能のサポート範囲」を参照してください。

4.1. Camel Kafka Connector の新機能

テクノロジーリビューの Camel Kafka Connector には、以下の主要機能が含まれています。

4.1.1. プラットフォームおよびコアコンポーネントのバージョン

  • OpenShift Container Platform 4.5 または 4.6
  • Red Hat Enterprise Linux 7.x, 8.x
  • AMQ Streams 1.5
  • Kafka Connect 2.5
  • Camel 3.5

4.1.2. テクノロジープレビューの機能

  • 一部の Camel Kafka コネクター
  • シンクおよびソースコネクターの Camel データフォーマットのマーシャリング/アンマーシャリング
  • シンクコネクターの集約
  • コネクターを拡張するための Maven archetype

4.1.3. テクノロジープレビューの Camel Kafka コネクター

表4.1 テクノロジープレビューの Camel Kafka コネクター

コネクターシンク/ソース

Amazon Web Services (AWS2) Kinesis

シンクおよびソース

Amazon Web Services (AWS2) S3

シンクおよびソース

Amazon Web Services (AWS2) SNS

シンクのみ

Amazon Web Services (AWS2) SQS

シンクおよびソース

Cassandra Query Language (CQL)

シンクおよびソース

Elasticsearch

シンクのみ

File

シンクのみ

Hadoop Distributed File System (HDFS)

シンクのみ

Hypertext Transfer Protocol (HTTP)

シンクのみ

Java Database Connectivity (JDBC)

シンクのみ

Java Message Service (JMS)

シンクおよびソース

MongoDB

シンクおよびソース

Salesforce

ソースのみ

Slack

ソースのみ

Syslog

ソースのみ

Timer

ソースのみ