structured streaming处理Kafka数据流

 package com.***;

    
  
    
 import org.apache.spark.api.java.function.MapFunction;
    
 import org.apache.spark.sql.*;
    
 import org.apache.spark.sql.streaming.StreamingQuery;
    
 import org.slf4j.Logger;
    
 import org.slf4j.LoggerFactory;
    
 import org.springframework.beans.factory.annotation.Value;
    
 import org.springframework.stereotype.Component;
    
  
    
 @Component
    
 public class KafkaStreaming2 implements IStreaming {
    
  
    
     private static Logger logger = LoggerFactory.getLogger(KafkaStreaming2.class);
    
  
    
     @Value("${kafka.bootstr