GitHub user dominikriemer added a comment to the discussion: Problem starting a 
MQTT adapter

@leniervm your understanding is correct, we are just talking about two 
different concepts:
* You can create an MQTT adapter or sink from any internal or external broker. 
When you create a new adapter, the source (e.g., the MQTT broker you're 
creating an adapter for) data is fetched from the broker, sent through the 
internal pre-processing pipeline and than sent to the internal StreamPipes 
messaging system for downstream computations.
* The internal system is used for routing data between data streams, processors 
and sinks. This internal system can also be configured and can be selected from 
one of the supported brokers (Kafka, Pulsar, MQTT, Nats). 

So the easiest way to solve your problem is to rely on the default 
configuration in the `docker-compose.minimal.yml` file and setting 
`SP_PRIORITIZED_PROTOCOL` to nats. You will still be able to create MQTT 
adapters and sinks from any broker which is reachable from the extension 
service, the only difference is that internal messages will be sent over the 
internal Nats broker.

Hope this helps!

GitHub link: 
https://github.com/apache/streampipes/discussions/3030#discussioncomment-10063428

----
This is an automatically sent email for [email protected].
To unsubscribe, please send an email to: [email protected]

Reply via email to