修复扫描

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

@@ -14,11 +14,15 @@ public class KafkaCustomerExample {
    private static final int PULL_NUM = 100;
    private static final String SERVERS = "47.105.160.21:9091,47.105.160.21:9092,47.105.160.21:9093";
    private static final String DESERIALIZER = "org.apache.kafka.common.serialization.StringDeserializer";
    public static void main(String[] args) throws InterruptedException {
        Properties properties = new Properties();
        properties.put("bootstrap.servers", "47.105.160.21:9091,47.105.160.21:9092,47.105.160.21:9093");
        properties.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
        properties.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
        properties.put("bootstrap.servers", SERVERS);
        properties.put("key.deserializer", DESERIALIZER);
        properties.put("value.deserializer", DESERIALIZER);
        properties.put(ConsumerConfig.GROUP_ID_CONFIG ,"test") ;
        properties.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, "true");
        properties.put(ConsumerConfig.AUTO_COMMIT_INTERVAL_MS_CONFIG, "1000");

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

@@ -13,11 +13,15 @@ import java.util.Scanner;
public class KafkaProducerExample {
    private static final Log logger = LogFactory.getLog(KafkaProducerExample.class);
    private static final String SERVERS = "47.105.160.21:9091,47.105.160.21:9092,47.105.160.21:9093";
    private static final String DESERIALIZER = "org.apache.kafka.common.serialization.StringDeserializer";
    public static void main(String[] args){
        Properties properties = new Properties();
        properties.put("bootstrap.servers", "47.105.160.21:9091,47.105.160.21:9092,47.105.160.21:9093");
        properties.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
        properties.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
        properties.put("bootstrap.servers", SERVERS);
        properties.put("key.serializer", DESERIALIZER);
        properties.put("value.serializer", DESERIALIZER);
        properties.put("request.required.acks", "all");
        KafkaProducer<String, String> producer = new KafkaProducer<String, String>(properties);
        try {