apache / apache/plc4x-extras

Kafka Connect and OPC UA Integration

Open
#330 5 comments 0 reactions 0 assignees View on GitHub
java
Dominant language
Go
Stars
19
Forks
20
Avg merge
4h 21m
Merged PRs (30d)
6

Description

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"
}

Contributor guide

No contributing guide indexed for this repository

Research direction

Start with the supplied Kafka Connect JSON configuration and inspect the connector status and logs while checking Conduktor for the expected opc39 topic. Verify whether the OPC UA connection, job, tag, and topic settings are accepted, and consider the issue resolved when the connector runs successfully and produces the expected topic or identifies a clear configuration error.

Written by the indexing model from the issue text.

Assessment

Tech stack
kafka
Domain
data-engineering
Issue type
Bug
Difficulty
4/5
Estimated time
3-5 days
Activity status
Active
Clarity
Needs clarification
Newbie friendliness
35/100

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.