cancel
Showing results for 
Search instead for 
Did you mean: 

Subscribe to Event Mesh Topic with MQTT Consumer in Data Intelligence

sele_eh
Explorer
0 Kudos
985

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.

View Entire Topic
Tobias_Griebe
Product and Topic Expert
Product and Topic Expert
0 Kudos

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

0 Kudos

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
Explorer
0 Kudos

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
Advisor
Advisor
0 Kudos

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
Participant
0 Kudos

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.