You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
This repository includes a Kubernetes yaml file called `strimzi.kafkaconnect.yaml` for use with the [Strimzi](https://strimzi.io) operator. Strimzi provides a simplified way of running the Kafka Connect distributed worker, by defining either a KafkaConnect resource or a KafkaConnectS2I resource.
123
+
This repository includes a Kubernetes yaml file called `strimzi.kafkaconnector.yaml` for use with the [Strimzi](https://strimzi.io) operator. Strimzi provides a simplified way of running the Kafka Connect distributed worker, by defining either a KafkaConnect resource or a KafkaConnectS2I resource.
124
124
125
125
The KafkaConnectS2I resource provides a nice way to have OpenShift do all the work of building the Docker images for you. This works particularly nicely combined with the KafkaConnector resource that represents an individual connector.
126
126
127
127
The following instructions assume you are running on OpenShift and have Strimzi 0.16 or later installed.
128
128
129
129
#### Start a Kafka Connect cluster using KafkaConnectS2I
130
-
1. Create a file called `kafkaconnect.yaml` containing the definition of a KafkaConnectS2I resource. Configure it with information it needs to connect to your Kafka cluster. You must include the annotation `strimzi.io/use-connector-resources: "true"` to configure it to use KafkaConnector resources so you can avoid needing to call the Kafka Connect REST API directly.
131
-
1.`oc apply -f kafkaconnect.yaml` to create the cluster, which usually takes several minutes.
130
+
1. Create a file called `kafka-connect-s2i.yaml` containing the definition of a KafkaConnectS2I resource. Configure it with the information it needs to connect to your Kafka cluster. You must include the annotation `strimzi.io/use-connector-resources: "true"` to configure it to use KafkaConnector resources so you can avoid needing to call the Kafka Connect REST API directly.
131
+
1.`oc apply -f kafka-connect-s2i.yaml` to create the cluster, which usually takes several minutes.
1.`oc start-build <kafkaconnectClusterName>-connect --from-dir ./myplugins` to add the MQ source connector to the Kafka Connect distributed worker cluster. Wait for the build to complete, which usually takes a few minutes.
1.`oc start-build <kafkaconnectClusterName>-connect --from-dir ./my-plugins` to add the MQ source connector to the Kafka Connect distributed worker cluster. Wait for the build to complete, which usually takes a few minutes.
138
138
1.`oc describe kafkaconnects2i <kafkaConnectClusterName>` to check that the MQ source connector is in the list of available connector plugins.
139
139
140
140
#### Start an instance of the MQ source connector using KafkaConnector
0 commit comments