Код ошибки 128 при попытке подписаться на топик в mqtt

В качестве брокера используется hbmqtt 0.9.6, в качестве клиента paho-mqtt 1.5.1. Сам протокол версии 3.1.1.

Конфигурация брокера:

listeners:
    default:
        type: tcp
    halp:
        max-connections: 33
        bind: 127.0.0.3:1883
topic-check:
    enabled: false
auth:
    allow-anonymous: true

Код клиента:

import paho.mqtt.client as mqtt

def on_connect(client, userdata, flags, rc):
    print("Connected with result code "+str(rc))
    client.subscribe('abc')

def on_message(client, userdata, msg):
    print(msg.topic + " " + str(msg.payload))

def on_subscribe(mosq, obj, mid, qos):
    print("Subscribed: " + str(mid))
    print("Granted QoS: " + str(qos[0]))

client = mqtt.Client(client_id="subscriber", transport="tcp")

client.on_connect = on_connect
client.on_message = on_message
client.on_subscribe = on_subscribe

client.connect("127.0.0.3", 1883)

client.loop_forever()

Соединение с брокером происходит без проблем, также если добавить публикующего клиента (с примерно таким же кодом), то брокер принимает сообщения и пытается их бродкастить
Что попробовано:

  1. Изменение имени топика
  2. Изменение айпи\порта
  3. Изменение транспорта

Ответы (0 шт):