Skip to content

Commit

Permalink
fix: Complete the renaming of the config options
Browse files Browse the repository at this point in the history 
Signed-off-by: Dale Lane <[email protected]>

Signed-off-by: Dale Lane <[email protected]>
  • Loading branch information
@dalelane
dalelane authored Dec 12, 2024
1 parent f4386eb commit 0ca58aa
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
6 changes: 3 additions & 3 deletions README.md
View file
Original file line number Diff line number Diff line change
Expand Up @@ -305,9 +305,9 @@ The configuration options for the Kafka Connect source connector for IBM MQ are
| mq.message.mqmd.read | Whether to enable reading of all MQMD fields | boolean | false | |
| mq.max.poll.blocked.time.ms | How long the connector will wait for the previous batch of messages to be delivered to Kafka before starting a new poll | integer | 2000 | It is important that this is less than the time defined for `task.shutdown.graceful.timeout.ms` as that is how long connect will wait for the task to perform lifecycle operations. |
| mq.client.reconnect.options | Options governing MQ reconnection. | string | ASDEF | ASDEF, ANY, QMGR, DISABLED |
| mq.receive.timeout | The timeout in milliseconds for receiving messages from JMS Consumer. | long | 2000 | 1 or greater |
| mq.reconnect.delay.min.ms | The minimum delay in milliseconds for reconnect attempts. | long | 64 | 1 or greater |
| mq.reconnect.delay.max.ms | The maximum delay in milliseconds for reconnect attempts. | long | 8192 | 1 or greater |
| mq.message.receive.timeout | The timeout (in milliseconds) for receiving messages from the queue manager before returning to Kafka Connect. | long | 2000 | 1 or greater |
| mq.reconnect.delay.min.ms | The minimum delay (in milliseconds) for reconnecting to the queue manager after a connection error. | long | 64 | 1 or greater |
| mq.reconnect.delay.max.ms | The maximum delay (in milliseconds) for reconnecting to the queue manager after a connection error. | long | 8192 | 1 or greater |

### Using a CCDT file

Expand Down
2 changes: 1 addition & 1 deletion src/integration/java/com/ibm/eventstreams/connect/mqsource/MQSourceTaskIT.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -86,7 +86,7 @@ private Map<String, String> createDefaultConnectorProperties() {
props.put("mq.queue", DEFAULT_SOURCE_QUEUE);
props.put("mq.user.authentication.mqcsp", "false");
props.put("topic", "mytopic");
props.put("mq.receive.timeout", "5000");
props.put("mq.message.receive.timeout", "5000");
props.put("mq.reconnect.delay.min.ms", "100");
props.put("mq.reconnect.delay.max.ms", "10000");
return props;
Expand Down

0 comments on commit 0ca58aa

Please sign in to comment.