kafka-connect-transform-xml

kafka-connect-transform-xml copied to clipboard

I am trying to start a new connector which reads an xml from a mqtt broker and transforms the xml into json and sends the json to a kafka topic....

manojrawat650

Hi people, First, I want to thanks about this connector. I have a question about the connector. I have many xml payloads arriving in kafka topic, and I need to...

alecomputacao

Referenced XSD's

2

Hello how are you? We have got a business scenario where we need to read an XML file and validate against a set of referenced schemas (But not single schema)...

christdist

Errors using books.xml : `Exception thrown while processing: Exception thrown while building field 'book'. BooksForm`

1

version 0.1.0.18 Using the unit test file [books.xml](https://raw.githubusercontent.com/jcustenborder/kafka-connect-transform-xml/master/src/test/resources/com/github/jcustenborder/kafka/connect/transform/xml/books.xml) and accompanying [books.xsd](https://raw.githubusercontent.com/jcustenborder/kafka-connect-transform-xml/master/src/test/resources/com/github/jcustenborder/kafka/connect/transform/xml/books.xsd) the SMT throws an error. Config: ``` curl -i -X PUT -H "Content-Type:application/json" \ http://localhost:8083/connectors/source-file-01/config \ -d '{ "connector.class":...

rmoff

Versions: jcustenborder/kafka-connect-transform-xml:0.1.0.18 ``` 2020-10-08 16:59:03,806 ERROR Failed to start task kafka.ibm-mq.source.connector.tomo-0 (org.apache.kafka.connect.runtime.Worker) [pool-5-thread-8] org.apache.kafka.connect.errors.ConnectException: java.lang.NullPointerException at org.apache.kafka.connect.runtime.ConnectorConfig.transformations(ConnectorConfig.java:264) at org.apache.kafka.connect.runtime.Worker.buildWorkerTask(Worker.java:513) at org.apache.kafka.connect.runtime.Worker.startTask(Worker.java:465) at org.apache.kafka.connect.runtime.distributed.DistributedHerder.startTask(DistributedHerder.java:1140) at org.apache.kafka.connect.runtime.distributed.DistributedHerder.access$1700(DistributedHerder.java:125) at org.apache.kafka.connect.runtime.distributed.DistributedHerder$13.call(DistributedHerder.java:1155) at org.apache.kafka.connect.runtime.distributed.DistributedHerder$13.call(DistributedHerder.java:1151) at...

schugie

This would give another option for further processing if a record fails to conform to a schema other than logging it.

abraham-leal

ERROR: White spaces are required between publicId and systemId

2

Version 0.1.0.18 Installed using: ``` confluent-hub install --no-prompt jcustenborder/kafka-connect-transform-xml:0.1.0.18 ``` Config: ``` curl -i -X PUT -H "Content-Type:application/json" http://localhost:8083/connectors/source-file-01/config \ -d '{ "connector.class": "org.apache.kafka.connect.file.FileStreamSourceConnector", "tasks.max": "1", "file": "/tmp.xml", "topic": "xmltest",...

rmoff

jcustenborder

Adding support to JAXB for JDK 9+

joaosal

Unable to parse XSD file. Gatting exceptions

1

 Hi Dev Team, I am a petty new in the Kafka world. I have a requirement where we are reading data from...

msrrasal