Chapter 5. Kafka breaking changes
This section describes any changes to Kafka that required a corresponding change to AMQ Streams to continue to work.
5.1. Using Kafka’s example file connectors
Kafka no longer includes the example file connectors FileStreamSourceConnector
and FileStreamSinkConnector
in its CLASSPATH
and plugin.path
by default. AMQ Streams has been updated so that you can still use these example connectors. The examples now have to be added to the plugin path like any connector.
Two example connector configuration files are provided:
-
examples/connect/kafka-connect-build.yaml
provides a Kafka Connectbuild
configuration, which you can deploy to build a new Kafka Connect image with the file connectors. -
examples/connect/source-connector.yaml
provides the configuration required to deploy the file connectors asKafkaConnector
resources.
See Deploying example KafkaConnector resources and Extending Kafka Connect with connector plugins.