sonar扫描

comp-example/src/test/java/com/ai/ipu/example/kafka/KafkaCustomerExample.java

@@ -6,6 +6,7 @@ import org.apache.kafka.clients.consumer.ConsumerConfig;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.apache.kafka.clients.consumer.ConsumerRecords;
import org.apache.kafka.clients.consumer.KafkaConsumer;
import java.util.Arrays;
import java.util.Properties;

comp-example/src/test/java/com/ai/ipu/example/kafka/KafkaProducerExample.java

@@ -5,8 +5,6 @@ import org.apache.commons.logging.LogFactory;
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerRecord;
import java.util.ArrayList;
import java.util.List;
import java.util.Properties;
import java.util.Scanner;

comp-example/src/test/java/com/ai/ipu/example/rocketmq/RocketMQProducerExample.java

@@ -21,8 +21,6 @@ public class RocketMQProducerExample {
        producer.setVipChannelEnabled(false);
        producer.setNamesrvAddr("47.105.160.21:9876");
        producer.start();
        try {
            Scanner sc = new Scanner(System.in);
            int i = 0;