PLC4X -Kafka连接器
PLC4X -Kafka连接器
提问于 2022-05-06 09:17:24
我想使用PLC4X连接器(https://www.confluent.io/hub/apache/kafka-connect-plc4x-plc4j)将OPC (Prosys模拟服务器)与Kafka连接起来。
然而，我真的没有找到任何描述卡夫卡连接配置选项的网站？
我试图连接到prosys opc ua模拟服务器，而不是将数据流到kafka主题。我管理它只是发送数据并使用它，但是我想使用模式和avro连接程序。
我来自接收器python连接器的输出如下所示。对我来说也有点奇怪吗？
b'Struct{fields=Struct{ff=-5.4470555688606E8,hhh=Sean Ray MD},timestamp=1651838599206}'如何将PLC4X连接器与Avro转换器和架构一起使用？
谢谢!
{
"connector.class": "org.apache.plc4x.kafka.Plc4xSourceConnector",
"default.topic":"plcTestTopic",
"connectionString":"opcua.tcp://127.0.0.1:12345",
"tasks.max": "2",
"sources": "machineA",
"sources.machineA.connectionString": "opcua:tcp://127.0.0.1:12345",
"sources.machineA.jobReferences": "jobA",
"jobs": "jobA",
"jobs.jobA.interval": "5000",
"jobs.jobA.fields": "job1,job2",
"jobs.jobA.fields.job1": "ns=2;i=2",
"jobs.jobA.fields.job2": "ns=2;i=3"
}回答 1
Stack Overflow用户
发布于 2022-05-07 22:34:50
当在Avro和注册表中使用架构时，应该使用以下设置。您还可以选择对键和值使用不同的设置。
key.converter=io.confluent.connect.avro.AvroConverter
value.converter=io.confluent.connect.avro.AvroConverter
key.converter.schema.registry.url:http://127.0.0.1:8081
value.converter.schema.registry.url:http://127.0.0.1:8081
key.converter.schemas.enable=true
value.converter.schemas.enable=true样例配置文件也可以在PLC4X Github存储库中获得。
https://github.com/apache/plc4x/tree/develop/plc4j/integrations/apache-kafka/config
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/72139051
复制相关文章
相似问题
腾讯云开发者
