<p>I am using Kafka with strimzi operator, I created a Kafka cluster and and also deployed Kafka connect using yml file. But after this I am totally blank what to do next . I read that Kafka connect is used to copy data from a source to Kafka cluster or from Kafka cluster to another destination.
I want to use Kafka connect to copy the data from a file to Kafka cluster's any topic.
Can any one please help me how can I do that I am sharing the yml file using which I created my Kafka connect cluster.</p>
<pre><code>apiVersion: kafka.strimzi.io/v1beta1

kind: KafkaConnect

metadata:

  name: my-connect-cluster

#  annotations:

#  # use-connector-resources configures this KafkaConnect

#  # to use KafkaConnector resources to avoid

#  # needing to call the Connect REST API directly

#    strimzi.io/use-connector-resources: &quot;true&quot;

spec:

  version: 2.6.0

  replicas: 1

  bootstrapServers: my-cluster-kafka-bootstrap:9093

  tls:

    trustedCertificates:

      - secretName: my-cluster-cluster-ca-cert

        certificate: ca.crt

  config:

    group.id: connect-cluster

    offset.storage.topic: connect-cluster-offsets

    config.storage.topic: connect-cluster-configs

    status.storage.topic: connect-cluster-status
</code></pre>
<p>@kubeclt create -f kafka-connect.yml -n strimzi</p>
<p>After that pod for Kafka connect is in running status ,I don't know what to do next. Please help me.</p>

rohit290554
<p>Kafka Connect <a href="https://kafka.apache.org/documentation/#connect_rest" rel="nofollow noreferrer">exposes a REST API</a>, so you need to expose that HTTP endpoint from the Connect pods</p>
<blockquote>
<p>I read that Kafka connect is used to copy data from a source to Kafka cluster or from Kafka cluster to another destination.</p>
</blockquote>
<p>That is one application, but sounds like you want <a href="https://strimzi.io/docs/operators/latest/overview.html#configuration-points-topic_str" rel="nofollow noreferrer">MirrorMaker2</a> instead for that</p>
<hr />
<p>If you don't want to use the REST API, then uncomment this line</p>
<pre><code>#    strimzi.io/use-connector-resources: &quot;true&quot;
</code></pre>
<p>and use another YAML file to configure the Connect resources , <a href="https://strimzi.io/blog/2020/01/27/deploying-debezium-with-kafkaconnector-resource/" rel="nofollow noreferrer">as shown here for Debezium</a>. See <code>kind: &quot;KafkaConnector&quot;</code></p>
