Kafka logical source using Web of Things (WoT)

[idomingu]

Would be great to support Kafka as a logical source using the WoT ontology, just like it has already been done for data sources of MQTT or WebSocket type (https://github.com/RMLio/RMLStreamer/blob/development/src/test/resources/WoT)

Here is an example of a Kafka source (extracted from RML-IO specification):

<#KafkaStream> a rml:LogicalSource;
    rml:source [ a rml:Source, td:Thing;
        td:hasPropertyAffordance [
            td:hasForm [
                # URL and content type
                hctl:hasTarget "kafka://localhost:8089/topic";
                hctl:forContentType "application/xml";
                # Kafka parameters through W3C WoT Binding Template for Kafka
                kafka:groupId "MyAwesomeGroup";
            ];
        ];
    ];
    rml:referenceFormulation rml:XPath;
    rml:iterator "/my/xpath";

This extension would improve the interoperability of RMLStreamer with the Web of Things and YARRRML.

Many thanks!