Questions tagged [mqtt-vernemq]

From webpage: VerneMQ is a high-performance, distributed MQTT broker (server). It scales both horizontally (via clustering) and vertically.

Official website: https://vernemq.com/

76 questions
9
votes
0 answers

MQTT Connection Fails on Google Container OS

For my setup, I'm working with a third party MQTT VerneMQ broker hosted in AWS. I have been given username/password credentials to connect over secure MQTT (port 8883) using a specific clientId. My goal (though irrelevant to the issue at hand) is…
5
votes
2 answers

Bridging an MQTT broker to 2 remote MQTT brokers simultaneously

We have many local gateways installed at different premises. These gateways will host an MQTT broker for connecting all the local services. Then it is required that the local MQTT broker sends this data to two remote MQTT brokers (each hosted with a…
maulik13
  • 3,656
  • 1
  • 25
  • 36
4
votes
4 answers

Failing to establish mqtt connection to VerneMQ cluster in k8s behind Istio proxy

I'm setting up k8s on-prem k8s cluster. For tests I use single-node cluster on vm set up with kubeadm. My requirements include running MQTT cluster (vernemq) in k8s with external access via Ingress (istio). Without deploying ingress, I can connect…
3
votes
1 answer

Any implications of using UUIDs in MQTT topic names?

I am doing a request/response flow using a MQTT broker and I wondered if brokers like VerneMQ or Mosquitto deal well with huge amount of topics. Basically every time I want to do a request/response, I publish to a topic that looks like rpc/{UUID}…
BinarSkugga
  • 400
  • 2
  • 15
3
votes
2 answers

Using MQTT behind proxy using PAHO c / cpp

So I have my paho client behind a ccproxy server with sock enabled. The problem is in paho python lib there is a method exposed for setting proxy client.proxy_set(proxy_type=socks.HTTP, proxy_addr="192.168.1.7", proxy_port=808) Can someone guide me…
Daniel Euchar
  • 1,740
  • 5
  • 28
  • 45
3
votes
1 answer

vernemq cluster node terminate due to remote_node_not_available

I am trying to setup vernemq cluster on Kubernetes using StatefulSet. Following is my manifest file. apiVersion: v1 kind: ConfigMap metadata: name: vernemq namespace: dev-ethernet data: vernemq.conf: | accept_eula = yes …
roy
  • 6,344
  • 24
  • 92
  • 174
3
votes
3 answers

VerneMQ on Kubernetes cluster

I'm trying to install VerneMQ on a Kubernetes cluster over Oracle OCI usign Helm chart. The Kubernetes infrastructure seems to be up and running, I can deploy my custom microservices without a problem. I'm following the instructions from…
2
votes
1 answer

Vernemq port 1883 with haproxy-ingress and also SSL termination

I'm trying to deploy vernemq on kubernetes and want to access it with subdomain with ssl but ssl should be terminated before request go to vernemq on port 1883.
2
votes
0 answers

"can't register client due to register_subscriber_retry_exhausted " when renewing a connection to VerneMQ

We have a Flask app that needs to send messages to different subscriptions on a VernqMQ broker. We are using paho.mqtt library to connect to the broker, and we are using JWT-based authentication, which is validated ok the broker with a custom…
tutiplain
  • 1,427
  • 4
  • 19
  • 37
2
votes
1 answer

Get active number of clients connected to Vernemq broker

I have a Vernemq broker running in a docker container,and I want to know the number of active clients at a given point of time.I am currently using the $SYS/broker/queue/processes topic to get the active processes, but I am not sure if this is the…
user3615045
  • 193
  • 2
  • 13
2
votes
0 answers

Mqtt client does not receive offline messages from VerneMq

We have an mqtt server (VerneMq on Linux VM on Azure) which is configured like below max_inflight_messages=500 upgrade_outgoing_qos=on max_offline_messages=1000000 max_online_messages=1000000 persistent_client_expiration=1w in addition to it's…
2
votes
0 answers

test MQTT behaviours and events emitted

I need to test MQTT behaviors and events emitted by MQTT. E.g whenever I(mock device) publish to MQTT, the Handler gets called by it with valid params(tested this with iex but needs to automate the process) and I performs some actions on the data.…
2
votes
2 answers

Checking which node in a VerneMQ cluster a client is connected to

Is there a way to check which node in a VerneMQ cluster a client is connected to short of using something like WireShark?
ytw
  • 1,335
  • 2
  • 20
  • 42
1
vote
1 answer

Haproxy MQTT Connection limiting at just 30,000 connections per mqtt node

I am using haproxy to loadbalance my MQTT brokers cluster. Each MQTT Broker can handle up to 1,00,000 Connections easily. But the problem i am facing with haproxy is that is only handling upto30k connections per node. Whenever if any node is…
Daga Arihant
  • 464
  • 4
  • 19
1
vote
1 answer

what is the better practice when designing MQTT topics for thousands of devices of multiple customers?

I am developing a MQTT service and I am confused when I design the topics. I think there are two ways to do this: Topic data/customer-a Payload {"sensor-id":"23aafff2d23659cc97c557909de12f16","type":"demo","value":"hello world"} Topic…
Ming Lv
  • 11
  • 3
1
2 3 4 5 6