Kafka Connect and OPC UA Integration

[Marwen001-ia]

Hey!

I hope you're doing well.

I've been trying to create a Kafka Connect configuration in JSON to connect to an OPC UA server. However, I'm not seeing the expected topic appear in Conduktor. Could you help me troubleshoot this issue or suggest some ways to investigate what's going wrong?

Thanks !

This is my code JSON :

"connector.class": "org.apache.plc4x.kafka.Plc4xSourceConnector",
"default.topic": "opc39",
"jobs": "job",
"jobs.job.interval": "1000",
"jobs.job.tags": "alarm",
"jobs.job.tags.alarm": "ns=2;s=Studio.Tags.Application",
"key.converter": "org.apache.kafka.connect.storage.StringConverter",
"key.converter.schemas.enable": "false",
"sources": "opcserver",
"sources.opcserver.bufferSize": "1000",
"sources.opcserver.connectionString": "opcua:tcp://IP_Adresse_Server:Port?discovery=true",
"sources.opcserver.jobReferences": "job",
"sources.opcserver.pollReturnInterval": "5000",
"tasks.max": "1",
"value.converter": "org.apache.kafka.connect.storage.StringConverter",
"value.converter.schemas.enable": "false"

}

[chrisdutz]

As the guy who wrote the initial adapter, happy to help, but no longer for free. If you're willing to donate, I'm happy to be of assistance.

[Marwen001-ia]

Totally understand, and I appreciate all the work you've done. Would you be open to just pointing me in the right direction, not the full solution? That would already help a lot.

[chrisdutz]

Unfortunately not ... It's probably been something round 5 or more years since I last worked on it and would need to dig in to the codebase.

[Marwen001-ia]

No worries at all. I can imagine it’s not easy to revisit something after so many years. If anything comes back to you or you get a chance to peek at the code, I’d be super grateful!