search

ibm-messaging / kafka-connect-mq-sink

This repository contains a Kafka Connect sink connector for copying data from Apache Kafka into IBM MQ.
Apache License 2.0
35 stars 43 forks source link

Acknowledge on message delivery from Kafka to MQ #36

Closed bensooraj closed 4 years ago

bensooraj commented 4 years ago

Hi!

I am just familiarising myself with the MQ sink and source connectors. I want to thank you for this project and for all your efforts.

I have a question, is there someway I can get an acknowledge that the message has been actually sent to or delivered IBM MQ from Kafka? Maybe using the topic offset?

For example, when I do an MQ PUT using the mq-mqi-nodejs npm module I know for sure whether the request failed or not along with Message ID in the MQ Message Descriptor:

https://github.com/ibm-messaging/mq-mqi-nodejs/blob/932f5768e48cebe11697470c3fbdc46bea8a43ba/samples/amqsput.js#L66-L71

Thanks!

bensooraj commented 4 years ago

A gentle bump!

Would really appreciate any insights on this question.

AndrewJSchofield commented 4 years ago

Hi, I'm afraid not. The Kafka producer and consumer APIs are hidden away in the Kafka Connect runtime.

bensooraj commented 4 years ago

Thanks, @AndrewJSchofield for letting me know.