第4章 Kafka の重大な変更
このセクションでは、機能を継続するために AMQ Streams への対応する変更が必要な Kafka への変更について説明します。
4.1. Kafka のサンプルファイルコネクターの使用
Kafka は、デフォルトで、サンプルファイルコネクター FileStreamSourceConnector と FileStreamSinkConnector を CLASSPATH と plugin.path に含めなくなりました。AMQ Streams が更新され、これらのサンプルコネクターを引き続き使用できるようになりました。サンプルは、他のコネクターと同様にプラグインパスに追加する必要があります。
コネクター設定ファイルの 2 つのサンプルが提供されています。
-
examples/connect/kafka-connect-build.yamlは、Kafka Connectbuild設定を提供します。これをデプロイして、ファイルコネクターを使用して新しい KafkaConnect イメージをビルドすることができます。 -
examples/connect/source-connector.yamlは、ファイルコネクターをKafkaConnectorリソースとしてデプロイするために必要な設定を提供します。
Deploying example KafkaConnector resources および Extending Kafka Connect with connector plugins を参照してください。