kafka-connect-mq-source

kafka-connect-mq-source copied to clipboard

kafka producer task shutdown , but MQ listener is still running

1

I have encountered an issue where the KafkaProducer task failed, and shutdown, but the MQ listener (MQSourceTask) is still working , and consuming the messages from MQ, so basically the...

harry7ster

IBM MQ Admin reports too many connections when IBM MQ source connector is used

6

We have used IBM MQ source connector to push our data to kafka topics. Connector plugin is hosted in 2 of the Kafka connect instances present as part of our...

rashmidelampady

Hi! I found the pom file of project **_com.ibm.eventstreams.connect:kafka-connect-mq-source:1.3.1_** introduced **_14_** dependencies. However, among them, **_6_** libraries (**_42%_**) are not used by your project. I list the redundant dependencies below...

Celebrate-future

Key and partitioning support for arbitrary JMS Headers

1

Currently, `kafka-connect-mq-source` supports three distinct (logical) sources for specifying the kafka key: `JMSMessageID`, `JMSCorrelationID` (as well as the `Bytes` variant) and `JMSDestination` (see https://github.com/ibm-messaging/kafka-connect-mq-source#key-support-and-partitioning). We would like, however, to use...

j0xaf

Guarantees when moving messages from MQ to Kafka

1

I was looking for a detailed diagram showing protocols used to connect to MQ. All messages in MQ can move to a separate Queue so that the Kafka Connect Worker...

mohanr

No connectivity established with MQ in distributed mode

1

Hi, I am running kafka as AWS Service (MSK) and running kafka-connect as a pod in kubernetes. kafka-connect can establish connection with my MSK but there is no sign of...

jagendramishra

Occasionally with Kafka Connect, I see my IBMMQ SourceConnector's task go up and down, that is, the REST interface sometimes reports one task that is RUNNING and sometimes reports no...

harishanandan124

I am trying to pause the connector using the api (i.e. curl -X PUT localhost:8083/connectors/local-file-sink/pause) and I am seeing that the connector is paused but the tasks are not paused,...

harishanandan124

We are using JMSMessageId in mq.record.builder.key.header as suggested in README section to partitioning the kafka message and attach JMSMessageId as key to each record. As described in the documentation, record...

ChhatralaNirmal

Does it has specific MQ SSL/TLS relevant config items?

1

just want to know whether this plugin has its own specific SSL keystore/trust keystore...etc configuration items , or it all rely on the default Kafka connector SSL/JKS...etc configuration? Thanks a...

qingyuan18