mqtt-deadlock

Description

the mqtt to Kafka application receives 51 messages every 2 seconds after 20 hours of deadlock,

Reproducing

MainTest.class mqtt to kafka

Publisher.class Analog send message