MySQL的sql基本操作

为什么MySQL使用use语句一直报错
凑字数的：合适的JFK是否你看你说的，发上的诺瓦克利夫你上的，发

use mys;
而不是use database_mys;

use 数据库名
use mys

• 这有个类似的问题, 你可以参考下: https://ask.csdn.net/questions/335012
• 你也可以参考下这篇文章：高并发消费kafka数据存储到mysql
• 除此之外, 这篇博客: 使用kafka定时获取接口的数据并存到mysql数据库中的 八、发送消息组件 部分也许能够解决你的问题, 你可以仔细阅读以下内容或跳转源博客中阅读:
  

• package com.example.demo.kafka;
  
  import com.google.gson.Gson;
  import com.google.gson.GsonBuilder;
  import lombok.extern.slf4j.Slf4j;
  import org.springframework.beans.factory.annotation.Autowired;
  import org.springframework.kafka.core.KafkaTemplate;
  import org.springframework.stereotype.Component;
  
  
  @Component
  @Slf4j
  public class KafkaSender {
      @Autowired
      private KafkaTemplate<String, String> kafkaTemplate;
  
      private Gson gson = new GsonBuilder().create();
  
      /**
       * 发送消息
       *
       * @param topic        topic
       * @param kafkaMessage 消息体
       */
      public void send(String topic, KafkaMessage kafkaMessage) {
          if (kafkaMessage == null) {
              return;
          }
          log.info("Producer->send kafka topic {}, message = {}", topic, gson.toJson(kafkaMessage));
          kafkaTemplate.send(topic, gson.toJson(kafkaMessage));
      }
  
  }