Example configurations

The following examples show standalone and distributed mode configurations for the IBM MQ Source connector. Both examples require running Apache Kafka® and Connect—for a walk-through, see the Tutorial: Moving Data In and Out of Kafka.

Note

As of Confluent Platform 7.5, ZooKeeper is deprecated for new deployments. KRaft mode is recommended for new deployments. For more information, see the KRaft documentation page.

Standalone mode example

Use this configuration with standalone workers.

name=connector1
tasks.max=1
connector.class=io.confluent.connect.ibm.mq.IbmMQSourceConnector
# The following values must be configured and should match your environment.
kafka.topic=MyKafkaTopicName
mq.hostname=localhost
mq.transport.type=client
mq.queue.manager=QMA
mq.channel=SYSTEM.DEF.SVRCONN
jms.destination.name=testing
# The following define the information used to validate the license stored in Kafka
# or leave blank for a 30 day trial
confluent.license=
confluent.topic.bootstrap.servers=localhost:9092

Change the confluent.topic.* properties as required to suit your environment. If running on a single-node Kafka cluster you will need to include confluent.topic.replication.factor=1. Leave the confluent.license property blank for a 30 day trial. See the configuration options for more details.

Distributed mode example

Use this configuration with distributed mode. Complete the following steps to configure and start the connector:

1. Write the following JSON to connector.json, changing the confluent.topic.* properties as required to suit your environment. Leave the confluent.license property blank for a 30 day trial. If running on a single-node Kafka cluster, also include "confluent.topic.replication.factor":"1". See the configuration options for more details.

   {
     "name": "connector1",
     "config": {
       "connector.class": "io.confluent.connect.ibm.mq.IbmMQSourceConnector",
       "kafka.topic":"MyKafkaTopicName",
       "mq.hostname":"localhost",
       "mq.transport.type":"client",
       "mq.queue.manager":"QMA",
       "mq.channel":"SYSTEM.DEF.SVRCONN",
       "jms.destination.name":"testing",
       "confluent.license":"",
       "confluent.topic.bootstrap.servers":"localhost:9092"
     }
   }
   

2. Post the configuration to one of the Kafka Connect workers using curl, replacing http://localhost:8083/ with the endpoint of your Kafka Connect worker.

   curl -s -X POST -H 'Content-Type: application/json' --data @connector.json http://localhost:8083/connectors