Skip to content

Commit 4a988e5

Browse files
AndrewJSchofieldAndrewJSchofield
committed
Use MQ on maven.org
1 parent a8c58e4 commit 4a988e5

File tree

3 files changed

+21
-37
lines changed

3 files changed

+21
-37
lines changed

‎README.md

Lines changed: 15 additions & 24 deletions
Original file line numberDiff line numberDiff line change
@@ -10,8 +10,6 @@ To build the connector, you must have the following installed:
1010
* [Maven](https://maven.apache.org)
1111
* Java 7 or later
1212

13-
Download the MQ client JAR by following the instructions in [Getting the IBM MQ classes for Java and JMS](https://www-01.ibm.com/support/docview.wss?uid=swg21683398). Once you've accepted the license, download the *IBM MQ JMS and Java redistributable client* file (currently called `9.0.0.1-IBM-MQC-Redist-Java.zip`). Unpack the ZIP file.
14-
1513
Clone the repository with the following command:
1614
```shell
1715
git clone https://github.com/ibm-messaging/kafka-connect-mq-source.git
@@ -22,19 +20,12 @@ Change directory into the `kafka-connect-mq-source` directory:
2220
cd kafka-connect-mq-source
2321
```
2422

25-
Copy the JAR file `com.ibm.mq.allclient.jar` that you unpacked from the ZIP file earlier into the `kafka-connect-mq-source` directory.
26-
27-
Run the following command to create a local Maven repository containing just this file so that it can be used to build the connector:
28-
```shell
29-
mvn deploy:deploy-file -Durl=file://local-maven-repo -Dfile=com.ibm.mq.allclient.jar -DgroupId=com.ibm.mq -DartifactId=allclient -Dpackaging=jar -Dversion=9.0.0.1
30-
```
31-
3223
Build the connector using Maven:
3324
```shell
3425
mvn clean package
3526
```
3627

37-
Once built, the output is a single JAR called `target/kafka-connect-mq-source-0.2-SNAPSHOT-jar-with-dependencies.jar` which contains all of the required dependencies.
28+
Once built, the output is a single JAR called `target/kafka-connect-mq-source-0.3-SNAPSHOT-jar-with-dependencies.jar` which contains all of the required dependencies.
3829

3930

4031
## Running the connector
@@ -141,19 +132,19 @@ For troubleshooting, or to better understand the handshake performed by the IBM
141132
## Configuration
142133
The configuration options for the MQ Source Connector are as follows:
143134

144-
| Name | Description | Type | Default | Valid values |
145-
| ----------------------- | ----------------------------------------------------------- | ------- | ------------- | --------------------------- |
146-
| mq.queue.manager | The name of the MQ queue manager | string | | MQ queue manager name |
147-
| mq.connection.name.list | List of connection names for queue manager | string | | host(port)[,host(port),...] |
148-
| mq.channel.name | The name of the server-connection channel | string | | MQ channel name |
149-
| mq.queue | The name of the source MQ queue | string | | MQ queue name |
150-
| mq.user.name | The user name for authenticating with the queue manager | string | | User name |
151-
| mq.password | The password for authenticating with the queue manager | string | | Password |
152-
| mq.record.builder | The class used to build the Kafka Connect record | string | | Class implementing RecordBuilder |
153-
| mq.message.body.jms | Whether to interpret the message body as a JMS message type | boolean | false | |
154-
| mq.ssl.cipher.suite | The name of the cipher suite for TLS (SSL) connection | string | | Blank or valid cipher suite |
155-
| mq.ssl.peer.name | The distinguished name pattern of the TLS (SSL) peer | string | | Blank or DN pattern |
156-
| topic | The name of the target Kafka topic | string | | Topic name |
135+
| Name | Description | Type | Default | Valid values |
136+
| ----------------------- | ----------------------------------------------------------- | ------- | ------------- | -------------------------------- |
137+
| mq.queue.manager | The name of the MQ queue manager | string | | MQ queue manager name |
138+
| mq.connection.name.list | List of connection names for queue manager | string | | host(port)[,host(port),...] |
139+
| mq.channel.name | The name of the server-connection channel | string | | MQ channel name |
140+
| mq.queue | The name of the source MQ queue | string | | MQ queue name |
141+
| mq.user.name | The user name for authenticating with the queue manager | string | | User name |
142+
| mq.password | The password for authenticating with the queue manager | string | | Password |
143+
| mq.record.builder | The class used to build the Kafka Connect record | string | | Class implementing RecordBuilder |
144+
| mq.message.body.jms | Whether to interpret the message body as a JMS message type | boolean | false | |
145+
| mq.ssl.cipher.suite | The name of the cipher suite for TLS (SSL) connection | string | | Blank or valid cipher suite |
146+
| mq.ssl.peer.name | The distinguished name pattern of the TLS (SSL) peer | string | | Blank or DN pattern |
147+
| topic | The name of the target Kafka topic | string | | Topic name |
157148

158149

159150
## Future enhancements
@@ -171,7 +162,7 @@ For issues relating specifically to this connect, please use the [GitHub issue t
171162

172163

173164
## License
174-
Copyright 2017 IBM Corporation
165+
Copyright 2017, 2018 IBM Corporation
175166

176167
Licensed under the Apache License, Version 2.0 (the "License");
177168
you may not use this file except in compliance with the License.

‎pom.xml

Lines changed: 4 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
<?xml version="1.0" encoding="UTF-8"?>
22
<!--
3-
* Copyright 2017 IBM Corporation
3+
* Copyright 2017, 2018 IBM Corporation
44
*
55
* Licensed under the Apache License, Version 2.0 (the "License");
66
* you may not use this file except in compliance with the License.
@@ -20,7 +20,7 @@
2020
<groupId>com.ibm.mq.kafkaconnect</groupId>
2121
<artifactId>kafka-connect-mq-source</artifactId>
2222
<packaging>jar</packaging>
23-
<version>0.2-SNAPSHOT</version>
23+
<version>0.3-SNAPSHOT</version>
2424
<name>kafka-connect-mq-source</name>
2525
<organization>
2626
<name>IBM Corporation</name>
@@ -58,8 +58,8 @@
5858
</dependency>
5959
<dependency>
6060
<groupId>com.ibm.mq</groupId>
61-
<artifactId>allclient</artifactId>
62-
<version>9.0.0.1</version>
61+
<artifactId>com.ibm.mq.allclient</artifactId>
62+
<version>9.0.4.0</version>
6363
</dependency>
6464

6565
<dependency>
@@ -76,13 +76,6 @@
7676
</dependency>
7777
</dependencies>
7878

79-
<repositories>
80-
<repository>
81-
<id>local-maven-repo</id>
82-
<url>file:///${project.basedir}/local-maven-repo</url>
83-
</repository>
84-
</repositories>
85-
8679
<build>
8780
<plugins>
8881
<plugin>

‎src/main/java/com/ibm/mq/kafkaconnect/MQSourceConnector.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/**
2-
* Copyright 2017 IBM Corporation
2+
* Copyright 2017, 2018 IBM Corporation
33
*
44
* Licensed under the Apache License, Version 2.0 (the "License");
55
* you may not use this file except in compliance with the License.
@@ -79,7 +79,7 @@ public class MQSourceConnector extends SourceConnector {
7979
public static final String CONFIG_DOCUMENTATION_TOPIC = "The name of the target Kafka topic.";
8080
public static final String CONFIG_DISPLAY_TOPIC = "Target Kafka topic";
8181

82-
public static String VERSION = "0.2";
82+
public static String VERSION = "0.3";
8383

8484
private Map<String, String> configProps;
8585

0 commit comments

Comments
 (0)