connect-ibm-mq-source

IBM MQ Source connector

Objective

Quickly test IBM MQ Source connector.

Using IBM MQ Docker image

• Download 9.0.0.8-IBM-MQ-Install-Java-All.jar and place it in ./9.0.0.8-IBM-MQ-Install-Java-All.jar

How to run

Simply run:

$ ./ibm-mq.sh

Details of what the script is doing

The connector is created with:

$ curl -X PUT \
     -H "Content-Type: application/json" \
     --data '{
               "connector.class": "io.confluent.connect.ibm.mq.IbmMQSourceConnector",
                    "kafka.topic": "MyKafkaTopicName",
                    "mq.hostname": "ibmmq",
                    "mq.port": "1414",
                    "mq.transport.type": "client",
                    "mq.queue.manager": "QM1",
                    "mq.channel": "DEV.APP.SVRCONN",
                    "mq.username": "app",
                    "mq.password": "passw0rd",
                    "jms.destination.name": "DEV.QUEUE.1",
                    "jms.destination.type": "queue",
                    "confluent.license": "",
                    "confluent.topic.bootstrap.servers": "broker:9092",
                    "confluent.topic.replication.factor": "1"
          }' \
     http://localhost:8083/connectors/ibm-mq-source/config | jq .

Messages are sent to IBM MQ using:

$ docker exec -i ibmmq /opt/mqm/samp/bin/amqsput DEV.QUEUE.1 << EOF
Message 1
Message 2

EOF

Verify we have received the data in MyKafkaTopicName topic:

docker exec connect kafka-avro-console-consumer -bootstrap-server broker:9092 --property schema.registry.url=http://schema-registry:8081 --topic MyKafkaTopicName --from-beginning --max-messages 2

N.B: Control Center is reachable at http://127.0.0.1:9021