第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 | ソースのみ |