I created a kafka cluster through the confluent cloud website, i’m trying to connect it to MQTT proxy through Confluent CLI but when i launch the command to start mqtt proxy i keep getting this error :
I feel like i’m missing something in my kafka-mqtt-dev.properties but i don’t know what exactly. this is my dev.properties file :
bootstrap.servers=PLAINTEXT:// here i have my Bootstrap server link !
welcome to the forum
having a quick look it seems that your config is missing the authentication settings to connect to confluent cloud.
details are here:
here are the relevant settings which need to be added to your config file
# bootstrap server url
# security protocol
# sasl mechanism
# sasl jaas config
producer.sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username='api_key_from_confluent_cloud' password='api_secret_from_confluent_cloud';
# confluent cloud refuses to create topic if you use default replication factor of 1
It worked ! thank you. i have a last question if you don’t mind, is there any solution to implement MQTT proxy on the cloud ? because for the moment everything i’m using is on cloud except for the mqtt proxy that i start from my machine.
thank you in advance
hivemq cloud might be the right solution. at least there is a free version to try (some data limits)
and also a blog post about a possible setup
Ok thank you !
And can i use the Postgres sink connector to send my data to a Timescaledb database ?
thank you so much for your time and energy! I know that i’m asking too many questions but i’m new to this. but this is the last one : so I saw that in order to transfer my data from my cluster to the database through the connector, i need to set a message value schema.
the data that i’m supposed to get from my Iot devices is a json string in this form :
How can i configure my schema to get this time of message, because i tried to do one and keep getting null values in messages received by the topic.
Thank you in advance
did this some time ago, need to check my docs
basically defining a schema might be the best
some docs around schema registry
here are some information which might help