diff --git a/README.md b/README.md index 0b90458..e949202 100644 --- a/README.md +++ b/README.md @@ -39,7 +39,7 @@ :fire:项目视频我正在[Bilibili](https://space.bilibili.com/198434865/channel/collectiondetail?sid=435119)更新（**三连越多，更新越有动力哟**） -:fire:**10W+字，共97个文档，带你玩转austin**，详情可戳：[消息推送平台文档](https://mp.weixin.qq.com/s?__biz=MzI4Njg5MDA5NA==&mid=2247509165&idx=1&sn=3e3d9f8646da79e546d551cbf993ddae&chksm=ebd4e5acdca36cba400f4927b3144e3dbf42d69ae38022a315722c9d33b5369e8ba9b212c685&token=1580829198&lang=zh_CN#rd) +:fire:**10W+字，共97个文档，带你玩转austin**，详情可戳：[消息推送平台文档](https://mp.weixin.qq.com/s?__biz=MzI4Njg5MDA5NA==&mid=2247509248&idx=1&sn=804eb5f6471521e1ea6eaec9f74ddf09&chksm=ebd4e401dca36d175494337bc18ff71c265e4e07ad3ecd22f4b5b5f73efe7e247de2c614ad8a&token=888257127&lang=zh_CN#rd) ## 消息推送平台austin介绍 @@ -77,7 +77,7 @@ austin项目**强依赖**`MySQL`/`Redis`/(**大概需要2G内存**)，**弱依赖**`kafka`/`prometheus`/`graylog`/`flink`/`xxl-job`/`apollo`/`hive`(**完全部署所有的服务，大概16G内存**)。如果缺少相关的组件可戳：[安装相关组件教程](INSTALL.md)。 -> 实在想要`clone`项目后不用自己部署环境直接在**本地**启动`debug`，我这提供了[股东服务](https://mp.weixin.qq.com/s?__biz=MzI4Njg5MDA5NA==&mid=2247509165&idx=1&sn=3e3d9f8646da79e546d551cbf993ddae&chksm=ebd4e5acdca36cba400f4927b3144e3dbf42d69ae38022a315722c9d33b5369e8ba9b212c685&token=1580829198&lang=zh_CN#rd)，**直连**部署好的服务器。 +> 实在想要`clone`项目后不用自己部署环境直接在**本地**启动`debug`，我这提供了[股东服务](https://mp.weixin.qq.com/s?__biz=MzI4Njg5MDA5NA==&mid=2247509248&idx=1&sn=804eb5f6471521e1ea6eaec9f74ddf09&chksm=ebd4e401dca36d175494337bc18ff71c265e4e07ad3ecd22f4b5b5f73efe7e247de2c614ad8a&token=888257127&lang=zh_CN#rd)，**直连**部署好的服务器。 **1**、austin目前使用的MySQL版本**5.7x**，如果你使用的MySQL版本8.0，注意改变`pom.xml`所依赖的版本以及对应的连接信息。 @@ -112,7 +112,7 @@ austin项目交流群已经超过了两百人，添加我的**个人微信**备 ## 项目文档 -:fire:**10W+字，共97个文档，带你玩转austin**，详情可戳：[消息推送平台文档](https://mp.weixin.qq.com/s?__biz=MzI4Njg5MDA5NA==&mid=2247509165&idx=1&sn=3e3d9f8646da79e546d551cbf993ddae&chksm=ebd4e5acdca36cba400f4927b3144e3dbf42d69ae38022a315722c9d33b5369e8ba9b212c685&token=1580829198&lang=zh_CN#rd) +:fire:**10W+字，共97个文档，带你玩转austin**，详情可戳：[消息推送平台文档](https://mp.weixin.qq.com/s?__biz=MzI4Njg5MDA5NA==&mid=2247509248&idx=1&sn=804eb5f6471521e1ea6eaec9f74ddf09&chksm=ebd4e401dca36d175494337bc18ff71c265e4e07ad3ecd22f4b5b5f73efe7e247de2c614ad8a&token=888257127&lang=zh_CN#rd) ![](https://p9-juejin.byteimg.com/tos-cn-i-k3u1fbpfcp/e314973589d14d51a5dc280a95c7a48a~tplv-k3u1fbpfcp-watermark.image?) diff --git a/austin-support/src/main/java/com/java3y/austin/support/mq/kafka/KafkaSendMqServiceImpl.java b/austin-support/src/main/java/com/java3y/austin/support/mq/kafka/KafkaSendMqServiceImpl.java index d8b62d5..7f2ed26 100644 --- a/austin-support/src/main/java/com/java3y/austin/support/mq/kafka/KafkaSendMqServiceImpl.java +++ b/austin-support/src/main/java/com/java3y/austin/support/mq/kafka/KafkaSendMqServiceImpl.java @@ -38,9 +38,9 @@ public class KafkaSendMqServiceImpl implements SendMqService { if (StrUtil.isNotBlank(tagId)) { List
headers = Arrays.asList(new RecordHeader(tagIdKey, tagId.getBytes(StandardCharsets.UTF_8))); kafkaTemplate.send(new ProducerRecord(topic, null, null, null, jsonValue, headers)); - } else { - kafkaTemplate.send(topic, jsonValue); + return; } + kafkaTemplate.send(topic, jsonValue); } @Override diff --git a/austin-web/src/main/resources/application.properties b/austin-web/src/main/resources/application.properties index e948f00..80d7ee6 100644 --- a/austin-web/src/main/resources/application.properties +++ b/austin-web/src/main/resources/application.properties @@ -83,7 +83,7 @@ apollo.bootstrap.namespaces=${austin.default.apollo.namespace:boss.austin},dynam nacos.config.server-addr=${austin.nacos.addr.ip:austin-nacos}:${austin.nacos.addr.port:8848} nacos.config.username=${austin.nacos.username:nacos} nacos.config.password=${austin.nacos.password:nacos} -nacos.config.namespace=${austin.nacos.namespace:7df088cb-2221-4f8d-8ce5-b37e96055ad8} +nacos.config.namespace=${austin.nacos.namespace:60e2b165-d830-4163-a0e9-b97ec2f7164c} nacos.config.enabled=${austin.nacos.enabled} nacos.data-id=${austin.nacos.dataId:austin}