com.mmnn.dd.mq.exception.DatatransRuntimeException
        at com.mmnn.dd.mq.impl.consumer.ConsumerImpl.poll(ConsumerImpl.java:139)
        at com.mmnn.dd.ddservice.tranquility.consumer.ConsumerThread.run(ConsumerThread.java:72)
        at com.mmnn.dd.ddservice.tranquility.TranquilityWorkshop$CheckedRunner.run(TranquilityWorkshop.java:280)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
        at java.lang.Thread.run(Thread.java:748)
Caused by: org.apache.kafka.common.errors.WakeupException
        at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.maybeTriggerWakeup(ConsumerNetworkClient.java:375)
        at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:222)
        at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1005)
        at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:954)
        at com.mmnn.dd.mq.impl.consumer.ConsumerImpl.poll(ConsumerImpl.java:134)
        ... 5 more