隐藏某些能够使用的密码

springboot-demo/src/main/java/com/elab/example/springbootdemo/SpringbootDemoApplication.java

@@ -4,7 +4,7 @@ import com.elab.mq.rocket.anno.EnableRocketMQ;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 
-@SpringBootApplication
+@SpringBootApplication()
 @EnableRocketMQ
 //@EnableESTools
 //@Import({DefaultElasticSearchTemplate.class})

springboot-demo/src/test/java/com/elab/example/springbootdemo/kafka/KafkaTest.java

@@ -34,9 +34,9 @@ public class KafkaTest {
     private static final String ENCODING = "UTF-8";
     private static final String HTTP_METHOD = "POST";
     //购买的实例所在地域的 Region ID
-    private static final String REGION_ID = "cn-shanghai";
-    private static final String ACCESS_KEY = "LTAIWRlbq9unW05V";
-    private static final String ACCESS_KEY_SECRET = "6JXciPjrzfJGPWO1enoklG88GTo9DL";
+    private static final String REGION_ID = "";
+    private static final String ACCESS_KEY = "";
+    private static final String ACCESS_KEY_SECRET = "";
 
 
     public static void main(String[] args) {

springboot-demo/src/test/java/com/elab/example/springbootdemo/rocketmq/producerTest.java

@@ -40,7 +40,7 @@ public class producerTest {
         Message message = new Message();
         message.setBody(jsonObject.toJSONString().getBytes());
         message.setTags("");
-        SendResult sendResult = rocketMQTemplate.send("elab-rocketMQ", "tag", RandomUtils.randomString(5),
+        SendResult sendResult = rocketMQTemplate.send("elab-marketing-user", "tag", RandomUtils.randomString(5),
                 jsonObject.toJSONString().getBytes());
         SendStatus sendStatus = sendResult.getSendStatus();
         System.out.println("--->" + sendResult.toString());