kafka-connect-mq-sink
kafka-connect-mq-sink copied to clipboard
Sending messages to IBM MQ with a different encode than UTF-8
Hello!
I have 2 points here:
-
I'd like to know if there a way to send a message to a IBM MQ queue using a different encode (like "IBM500"). In my need, I noticed that there's data loss caused by the differences between a content that is received as EBCDIC (IBM500) and the default value used by IBM MQ Sink connector is UTF-8.
-
I'd like to know if is it possible to input a custom source code into the connector to force the ccsid.
PS.: I can't change the CCSID of que Queue Manager.
Hi @brenofr sorry it has taken so long to respond to this.
- Some details of message format options can be found in this section of the README which give some details about message formatting however is no reference to supporting alternative encodings.
- At the moment, this is not possible as the encoding is fixed to UTF-8. It might be possible to expose this as part of the connector config.
I will raise it with the development team.
Hi @brenofr, @jhughes24816 fyi,
I have just opened a PR on the IBM MQ source connector repo to add support for configuring the connector with a non-default CCSID: https://github.com/ibm-messaging/kafka-connect-mq-source/pull/125
Provided there are no issues with this going through, the same approach could be implemented for the sink connector.