<div dir="ltr"><div dir="ltr"><div dir="ltr"><div>Hi Haiou,<br></div><div><br></div><div>The Kafka Connect REST API is available on port 8083, as the <code><connect-cluster-name>-connect-api</code> service.</div><div><br></div><div>Using it is slightly awkward because it is not exposed outside the cluster. You should be able to use something like <br></div><div style="margin-left:40px">kubectl exec -ti $CONNECT_POD -- curl -X POST -H "Content-Type: application/json" --data '{"name": "inventory-connector", "config": {"connector.class": "io.debezium.connector.mongodb.MongoDbConnector","mongodb.hosts": "rs0/<a href="http://192.168.99.100:27017">192.168.99.100:27017</a>", "<a href="http://mongodb.name">mongodb.name</a>": "fullfillment", "collection.whitelist": "inventory[.]*"}}' <a href="http://localhost:8083/connectors">http://localhost:8083/connectors</a></div></div><div dir="ltr"></div><div dir="ltr"><br></div><div dir="ltr">(We have an issue for making the REST API accessible outside the cluster: <a href="https://github.com/strimzi/strimzi-kafka-operator/issues/130">https://github.com/strimzi/strimzi-kafka-operator/issues/130</a>)</div><div dir="ltr"><br></div><div>Regards,</div><div><br></div><div>Tom<br></div><div dir="ltr"><br></div></div></div><br><div class="gmail_quote"><div dir="ltr" class="gmail_attr">On Mon, Jan 28, 2019 at 3:27 PM Haiou Xiang <<a href="mailto:haiouxiang@gmail.com">haiouxiang@gmail.com</a>> wrote:<br></div><blockquote class="gmail_quote" style="margin:0px 0px 0px 0.8ex;border-left:1px solid rgb(204,204,204);padding-left:1ex"><div dir="ltr">I deployed strimzi kafka, strimzi zookeeper, strimzi kafka connector with debezium mongodb connect plugin and Mongodb replicaset on Kubernetes, and all PODs were deployed successfully. Next, according to Debezium document, I need do two steps in below.<br><div><span style="color:rgb(101,101,101);font-family:"Helvetica Neue",Helvetica,Arial,sans-serif;font-size:15px">" To use the connector to produce change events for a particular MongoDB replica set ,  </span></div><div><span style="color:rgb(101,101,101);font-family:"Helvetica Neue",Helvetica,Arial,sans-serif;font-size:15px">1. simply create a </span><a href="https://debezium.io/docs/connectors/mongodb/#configuration" style="box-sizing:border-box;background-image:initial;background-position:initial;background-size:initial;background-repeat:initial;background-origin:initial;background-clip:initial;color:rgb(51,102,153);text-decoration-line:none;font-family:"Helvetica Neue",Helvetica,Arial,sans-serif;font-size:15px;outline:currentcolor none medium" target="_blank">configuration file for the MongoDB Connector</a><span style="color:rgb(101,101,101);font-family:"Helvetica Neue",Helvetica,Arial,sans-serif;font-size:15px"> </span></div><div><span style="color:rgb(101,101,101);font-family:"Helvetica Neue",Helvetica,Arial,sans-serif;font-size:15px">2. use the </span><a href="http://docs.confluent.io/3.0.0/connect/userguide.html#rest-interface" style="box-sizing:border-box;background-image:initial;background-position:initial;background-size:initial;background-repeat:initial;background-origin:initial;background-clip:initial;color:rgb(51,102,153);text-decoration-line:none;font-family:"Helvetica Neue",Helvetica,Arial,sans-serif;font-size:15px;outline:currentcolor none medium" target="_blank">Kafka Connect REST API</a><span style="color:rgb(101,101,101);font-family:"Helvetica Neue",Helvetica,Arial,sans-serif;font-size:15px"> to add that connector to your Kafka Connect cluster. </span>  <br>   But does strimzi support Kafka connect rest API? if yes, how to invoke Kafka connect rest API. If not, how can I config Kafka connect, debezium mongodb connect and Mongodb in Kubernetes?</div><div><br></div><div>thanks,</div></div>
_______________________________________________<br>
Strimzi mailing list<br>
<a href="mailto:Strimzi@redhat.com" target="_blank">Strimzi@redhat.com</a><br>
<a href="https://www.redhat.com/mailman/listinfo/strimzi" rel="noreferrer" target="_blank">https://www.redhat.com/mailman/listinfo/strimzi</a><br>
</blockquote></div>