diff --git a/UsingMQwithKafkaConnect.md b/UsingMQwithKafkaConnect.md index bf728b2..6969938 100644 --- a/UsingMQwithKafkaConnect.md +++ b/UsingMQwithKafkaConnect.md @@ -34,60 +34,59 @@ It is assumed that you have installed MQ, you're logged in as a user authorized crtmqm -p 1414 MYQM ``` -1. Start the queue manager: +2. Start the queue manager: ``` shell strmqm MYQM ``` -1. Start the `runmqsc` tool to configure the queue manager: +3. Start the `runmqsc` tool to configure the queue manager: ``` shell runmqsc MYQM ``` -1. In `runmqsc`, create a server-connection channel: +4. In `runmqsc`, create a server-connection channel: ``` DEFINE CHANNEL(MYSVRCONN) CHLTYPE(SVRCONN) ``` -1. Set the channel authentication rules to accept connections requiring userid and password: +5. Set the channel authentication rules to accept connections requiring userid and password: ``` SET CHLAUTH(MYSVRCONN) TYPE(BLOCKUSER) USERLIST('nobody') SET CHLAUTH('*') TYPE(ADDRESSMAP) ADDRESS('*') USERSRC(NOACCESS) SET CHLAUTH(MYSVRCONN) TYPE(ADDRESSMAP) ADDRESS('*') USERSRC(CHANNEL) CHCKCLNT(REQUIRED) ``` -1. Set the identity of the client connections based on the supplied context, the user ID: +6. Set the identity of the client connections based on the supplied context, the user ID: ``` ALTER AUTHINFO(SYSTEM.DEFAULT.AUTHINFO.IDPWOS) AUTHTYPE(IDPWOS) ADOPTCTX(YES) ``` -1. Refresh the connection authentication information: +7. Refresh the connection authentication information: ``` REFRESH SECURITY TYPE(CONNAUTH) ``` -1. Create a queue for the connector to use: +8. Create a queue for the connector to use: ``` DEFINE QLOCAL(MYQSINK) ``` -1. Authorize `alice` to connect to and inquire the queue manager: +9. Authorize `alice` to connect to and inquire the queue manager: ``` SET AUTHREC OBJTYPE(QMGR) PRINCIPAL('alice') AUTHADD(CONNECT,INQ) ``` -1. Finally authorize `alice` to use the queue: +10. Finally authorize `alice` to use the queue: ``` SET AUTHREC PROFILE(MYQSINK) OBJTYPE(QUEUE) PRINCIPAL('alice') AUTHADD(ALLMQI) ``` -1. End `runmqsc`: +11. End `runmqsc`: ``` END ``` -The queue manager is now ready to accept connection from Kafka Connect connectors. - +The queue manager is now ready to accept connection from Kafka Connect connectors. ### Download and set up Apache Kafka These instructions assume you have Apache Kafka downloaded and running locally. See the [Apache Kafka quickstart guide](https://kafka.apache.org/quickstart) for more details. @@ -97,12 +96,12 @@ These instructions assume you have Apache Kafka downloaded and running locally. bin/zookeeper-server-start.sh config/zookeeper.properties ``` -1. In another terminal, start a Kafka server: +2. In another terminal, start a Kafka server: ``` shell bin/kafka-server-start.sh config/server.properties ``` -1. Create a topic called `TSINK` for the connector to pull event from: +3. Create a topic called `TSINK` for the connector to pull event from: ``` shell bin/kafka-topics.sh --zookeeper localhost:2181 --create --topic TSINK --partitions 1 --replication-factor 1 ``` @@ -134,7 +133,7 @@ Configure and run the connector: cp config/mq-sink.properties ~ ``` -1. Edit the following properties in the `~/mq-sink.properties` to match the configuration so far: +2. Edit the following properties in the `~/mq-sink.properties` to match the configuration so far: ``` topics=TSINK mq.queue.manager=MYQM @@ -145,7 +144,7 @@ Configure and run the connector: mq.password=passw0rd ``` -1. Change directory to the Kafka root directory. Start the connector worker replacing `` and `` with your directory and the connector version: +3. Change directory to the Kafka root directory. Start the connector worker replacing `` and `` with your directory and the connector version: ``` shell CLASSPATH=/target/kafka-connect-mq-sink--jar-with-dependencies.jar ./bin/connect-standalone.sh config/connect-standalone.properties ~/mq-sink.properties ``` diff --git a/pom.xml b/pom.xml index 4695ce6..ad85b0a 100644 --- a/pom.xml +++ b/pom.xml @@ -20,7 +20,7 @@ com.ibm.eventstreams.connect kafka-connect-mq-sink jar - 1.1.0 + 1.1.1 kafka-connect-mq-sink IBM Corporation @@ -45,13 +45,13 @@ org.apache.kafka connect-api - 2.0.0 + 2.3.0 provided org.apache.kafka connect-json - 2.0.0 + 2.3.0 provided diff --git a/src/main/java/com/ibm/eventstreams/connect/mqsink/MQSinkConnector.java b/src/main/java/com/ibm/eventstreams/connect/mqsink/MQSinkConnector.java index fbb389c..5338779 100644 --- a/src/main/java/com/ibm/eventstreams/connect/mqsink/MQSinkConnector.java +++ b/src/main/java/com/ibm/eventstreams/connect/mqsink/MQSinkConnector.java @@ -107,7 +107,7 @@ public class MQSinkConnector extends SinkConnector { public static final String CONFIG_DOCUMENTATION_MQ_REPLY_QUEUE = "The name of the reply-to queue, as a queue name or URI."; public static final String CONFIG_DISPLAY_MQ_REPLY_QUEUE = "Reply-to queue"; - public static String VERSION = "1.1.0"; + public static String VERSION = "1.1.1"; private Map configProps; diff --git a/src/main/java/com/ibm/eventstreams/connect/mqsink/MQSinkTask.java b/src/main/java/com/ibm/eventstreams/connect/mqsink/MQSinkTask.java index 23c942e..45d1e62 100644 --- a/src/main/java/com/ibm/eventstreams/connect/mqsink/MQSinkTask.java +++ b/src/main/java/com/ibm/eventstreams/connect/mqsink/MQSinkTask.java @@ -1,5 +1,5 @@ /** - * Copyright 2017, 2018 IBM Corporation + * Copyright 2017, 2018, 2019 IBM Corporation * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/src/test/java/com/ibm/eventstreams/connect/mqsink/MQSinkConnectorTest.java b/src/test/java/com/ibm/eventstreams/connect/mqsink/MQSinkConnectorTest.java index 2544193..f9fa5eb 100644 --- a/src/test/java/com/ibm/eventstreams/connect/mqsink/MQSinkConnectorTest.java +++ b/src/test/java/com/ibm/eventstreams/connect/mqsink/MQSinkConnectorTest.java @@ -1,5 +1,5 @@ /** - * Copyright 2017, 2018 IBM Corporation + * Copyright 2017, 2018, 2019 IBM Corporation * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/src/test/resources/log4j.properties b/src/test/resources/log4j.properties index 17df06c..514f678 100644 --- a/src/test/resources/log4j.properties +++ b/src/test/resources/log4j.properties @@ -1,5 +1,5 @@ # -# Copyright 2017 IBM Corporation +# Copyright 2017, 2018, 2019 IBM Corporation # # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License.