第4章 Kafka の重大な変更

このセクションでは、機能を継続するために AMQ Streams への対応する変更が必要な Kafka への変更について説明します。

4.1. Kafka のサンプルファイルコネクターの使用

Kafka は、デフォルトで、サンプルファイルコネクター FileStreamSourceConnectorFileStreamSinkConnectorCLASSPATHplugin.path に含めなくなりました。AMQ Streams が更新され、これらのサンプルコネクターを引き続き使用できるようになりました。サンプルは、他のコネクターと同様にプラグインパスに追加する必要があります。

コネクター設定ファイルの 2 つのサンプルが提供されています。

  • examples/connect/kafka-connect-build.yaml は、Kafka Connect build 設定を提供します。これをデプロイして、ファイルコネクターを使用して新しい KafkaConnect イメージをビルドすることができます。
  • examples/connect/source-connector.yaml は、ファイルコネクターを KafkaConnector リソースとしてデプロイするために必要な設定を提供します。

Deploying example KafkaConnector resources および Extending Kafka Connect with connector plugins を参照してください。