search

ibm-messaging / kafka-connect-mq-source

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

Avro schema problems with builders #100

Closed VenkatJav closed 1 year ago

VenkatJav commented 2 years ago

I have setup need to read the messages from MQ and post into the pre-defined schema with AVRO format. I try below and it's not working and getting errors. Any idea how can i make it work? incoming messages are not JSON format so i can't use the JSON record builders.

"mq.record.builder": "com.ibm.eventstreams.connect.mqsource.builders.DefaultRecordBuilder" "mq.message.body.jms": "true" "key.converter": "io.confluent.connect.avro.AvroConverter" "value.converter": "io.confluent.connect.avro.AvroConverter" "key.converter.schema.registry.url": "https://myschemaregistryURL:port", "value.converter.schema.registry.url": "https://myschemaregistryURL:port"

jhughes24816 commented 1 year ago

Hi @VenkatJav, This MQ connector has mostly been tested with the default Apache Kafka converters:

The Data formats section of the README explains how the connector works in this area.