Hi, Right now, the Kafka connector only supports polling from the data source. However, for 2024 I have planned to create a completely new scraper component, that will also support subscriptions. So right now, it doesn’t support it, but it’s on the schedule.
Chris Von: Hamze HAMZE <[email protected]> Datum: Dienstag, 19. Dezember 2023 um 12:00 An: [email protected] <[email protected]> Betreff: apache kafka and subscription mode Hello together, Do you know whether it is possible to use the ChangeOfState Subscription mode at retrieving data from OPCUA by the Apache Kafka Connector? I have her an example configuration and would like to know how and by which variable this could be possible. { "name": "PLC4X-OPCUA-Connector", "config": { "connector.class": "org.apache.plc4x.kafka.Plc4xSourceConnector", "tasks.max": "1", "default.topic": "PLC_opcua", "sources.opcua.connectionString": "opcua:tcp://xxx.xxx.xxx.xxx:4840", "sources.opcua.jobReferences": "L12", "jobs": "L12", "jobs.L12.interval":100, "jobs.L12.fields": "SN18", "jobs.L12.fields.SN18": "ns=3;s=\"TO\".\"SN18\"", "transforms": "extractField", "transforms.extractField.type": "org.apache.kafka.connect.transforms.ExtractField$Value", "transforms.extractField.field": "fields", "key.converter": "org.apache.kafka.connect.json.JsonConverter", "value.converter": "org.apache.kafka.connect.json.JsonConverter", "key.converter.schemas.enable": "false", "value.converter.schemas.enable": "false" } } Thank you in advance! -- Mit freundlichen Grüßen / Bien Cordialement / Kind regards / أطيب التحيات *Hamze HAMZE* Machine Learning Engineer +49 (0) 17630004907 [email protected] Valeo Schalter und Sensoren GmbH Valeostrasse 1 - 86650 - Wemding (GERMANY) [image: valeo] <https://valeo.com/> [image: linkedin] <https://linkedin.com/company/valeo> [image: twitter] <https://twitter.com/valeo_group> [image: youtube] <https://youtube.com/user/ValeoGroup> [image: facebook] <https://facebook.com/Valeo.Group/> [image: instagram] <https://instagram.com/valeo_group> Sitz der Gesellschaft: 74321 Bietigheim-Bissingen Handelsregister: Amtsgericht Stuttgart - HRB 301795 Vorsitzender des Aufsichtsrates: Dr. Andreas Heinrich Geschäftsführer: Stiv Michael Smudja, Martin Mandry, Pierre-Yves Veltois *This e-mail message is intended for the internal use of the intended recipient(s) only. The information contained herein is confidential/privileged. Its disclosure or reproduction is strictly prohibited. If you are not the intended recipient, please inform the sender immediately, do not disclose it internally or to third parties and destroy it. In the course of our business relationship and for business purposes only, Valeo may need to process some of your personal data. For more information, please refer to the Valeo Data Protection Statement and Privacy notice available on Valeo.com <https://www.valeo.com/en/ethics-and-compliance/#principes>* -- *This e-mail message is intended for the internal use of the intended recipient(s) only. The information contained herein is confidential/privileged. Its disclosure or reproduction is strictly prohibited. If you are not the intended recipient, please inform the sender immediately, do not disclose it internally or to third parties and destroy it. In the course of our business relationship and for business purposes only, Valeo may need to process some of your personal data. For more information, please refer to the Valeo Data Protection Statement and Privacy notice available on Valeo.com <https://www.valeo.com/en/ethics-and-compliance/#principes>*
