Subscribe to Event Mesh Topic with MQTT Consumer in Data Intelligence

[sele_eh]

Hello everyone,

is it possible to connect a MQTT Consumer (via Websocket Secure) in SAP Data Intelligence to an SAP Event Mesh Topic / Queue?

I don't seem to use the correct configuration parameter for the MQTT Consumer.

Basic Setup:

Config Param:

Broker: wss://<host-sys>.cfapps.eu10.hana.ondemand.com:<Port>/protocols/mqtt311ws
Port: 443 / 80
Topic: <namespace>/test (Setup and working properly with other applications)
Client ID: not sure... I Tried the xsappname provided by the Service Key in BTP

Since its wss:

Username and Password as provided by the Service Key.

Any help would be much appreciated, thank you!
L.

[Tobias_Griebe · Accepted solution]

Hi sele_eh and mert.karakilic,

I'm not an expert for this topic but to my knowledge there is a dedicated connector for Event Mesh (formerly known as Enterprise Messaging): https://help.sap.com/viewer/ca509b7635484070a655738be408da63/Cloud/en-US/0dc12b6387cc4969ae20cfa26eb...

This is at least available for SAP Data Intelligence Cloud.

Best regards,
Tobias

[kai-michael_roesner · Accepted solution]

It is also available in the on-prem version of Data Intelligence as of 3.1.4:

https://help.sap.com/viewer/b13b5722c8ff4bf9bb097251310031d0/3.1.latest/en-US/0dc12b6387cc4969ae20cf...

Please note that authentication is done using the OAuth 2.0 client credentials grant flow, i.e. you'll need to provide client ID and client secret from the Event Mesh service key.

[sele_eh · Accepted solution]

Hi Tobias Griebe,

thank you for your reply.
I did use the SAP CP EM Consumer Operator in a previous scenario. It does currently only support AMQP though.

Nevertheless I used the underlying JS Script to customize my own MQTT Operator.
Of note: Event Mesh currently only supports subscribing to Topics while using the MQTT protocol.

For anyone interested, have a look at the @sap/xb-msg-mqtt-v3111 js package:

https://www.npmjs.com/package/@sap/xb-msg-mqtt-v311

Best regards,
Lennart

[ravicondamoor · Accepted solution]

Hi,

What does 'not natively supported' mean? There is a DI Connection Type - CPEM, that allows you to connect to Event Mesh. What more would a 'native' support provide?

Cheers

-ravi

[mig1 · Accepted solution]

Lennart, did you manage to find any other way of connecting over MQTT than using the javascript package? I would love to use a client like MQTT X or similar but haven't found one that supports the OAuth flow required for Event Mesh; nor have a found a way to supply an access token generated elsewhere.