I am having this error show up occasionally using Alpakka MQTT streaming:
akka.stream.alpakka.mqtt.streaming.impl.Subscriber$SubscribeFailed$: null
My setup is:
- HiveMQ 4.1.1
- Alpakka-mqtt-streaming_2.12_1.1.0
- Scala 2.12.8
This is the stack trace:
2019-07-18 08:00:38,343 ERROR a.a.t.i.a.ActorAdapter [default-akka.actor.default-dispatcher-17] null
akka.stream.alpakka.mqtt.streaming.impl.Subscriber$SubscribeFailed$: null
2019-07-18 08:00:38,343 ERROR a.a.t.i.a.ActorAdapter [default-akka.actor.default-dispatcher-17] null
akka.stream.alpakka.mqtt.streaming.impl.Subscriber$SubscribeFailed$: null
2019-07-18 08:00:38,345 DEBUG a.s.a.m.s.i.Subscriber$ [default-akka.actor.default-dispatcher-2] Cancel all timers
2019-07-18 08:00:38,345 DEBUG a.s.a.m.s.i.Subscriber$ [default-akka.actor.default-dispatcher-2] Cancel all timers
2019-07-18 08:00:38,357 DEBUG a.s.Materializer [default-akka.actor.default-dispatcher-16] [client-commandFlow] Upstream failed, cause: ActorMqttClientSession$SubscribeFailed$: null
2019-07-18 08:00:38,357 DEBUG a.s.Materializer [default-akka.actor.default-dispatcher-16] [client-commandFlow] Upstream failed, cause: ActorMqttClientSession$SubscribeFailed$: null
2019-07-18 08:00:38,358 DEBUG a.a.RepointableActorRef [default-akka.actor.default-dispatcher-14] Aborting tcp connection to [redacted] because of upstream failure: akka.stream.alpakka.mqtt.streaming.scaladsl.ActorMqttClientSession$SubscribeFailed$
2019-07-18 08:00:38,358 DEBUG a.a.RepointableActorRef [default-akka.actor.default-dispatcher-14] Aborting tcp connection to [redacted] because of upstream failure: akka.stream.alpakka.mqtt.streaming.scaladsl.ActorMqttClientSession$SubscribeFailed$
2019-07-18 08:00:38,359 DEBUG a.s.Materializer [default-akka.actor.default-dispatcher-4] [client-events] Upstream failed, cause: ActorMqttClientSession$SubscribeFailed$: null
2019-07-18 08:00:38,359 DEBUG a.s.Materializer [default-akka.actor.default-dispatcher-4] [client-events] Upstream failed, cause: ActorMqttClientSession$SubscribeFailed$: null