kafka日志集成

admin

2021-08-02 e89de9319d8f771f8e53cb5f876d06465a580c57

 src/main/java/com/yeshi/buwan/util/mq/CMQUtil.java

@@ -298,7 +298,7 @@
                                  final List<String> filterTag) {
        try {
            topicAccount.createSubscribe(topicName, subscriptionName, queueName, "queue",
                    filterTag, null, null, null);
                    filterTag, null, "EXPONENTIAL_DECAY_RETRY", "JSON");
            return true;
        } catch (Exception e) {
            e.printStackTrace();