add test

dbsyncer-connector/pom.xml

@@ -56,8 +56,8 @@
 
         <!-- kafka -->
         <dependency>
-            <groupId>org.springframework.kafka</groupId>
-            <artifactId>spring-kafka</artifactId>
+            <groupId>org.apache.kafka</groupId>
+            <artifactId>kafka-clients</artifactId>
         </dependency>
 
     </dependencies>

dbsyncer-listener/src/main/test/KafkaClientTest.java

@@ -24,7 +24,7 @@ public class KafkaClientTest {
     private KafkaConsumer<String, String> consumer;
     private KafkaProducer<String, String> producer;
 
-    private String server = "192.168.100.100:9092";
+    private String server = "192.168.1.100:9092";
     private String cKeyDeserializer = "org.apache.kafka.common.serialization.StringDeserializer";
     private String cValueDeserializer = "org.apache.kafka.common.serialization.StringDeserializer";
     private String pKeySerializer = "org.apache.kafka.common.serialization.StringSerializer";
@@ -95,7 +95,7 @@ public class KafkaClientTest {
             while (true) {
                 ConsumerRecords<String, String> records = consumer.poll(100);
                 for (ConsumerRecord<String, String> record : records) {
-                    logger.info("offset = %d, key = %s, value = %s%n", record.offset(), record.key(), record.value());
+                    logger.info("收到消息：offset = {}, key = {}, value = {}", record.offset(), record.key(), record.value());
                 }
             }
         }
@@ -110,7 +110,7 @@ public class KafkaClientTest {
         @Override
         public void run() {
             for (int i = 0; i < 100; i++) {
-                producer.send(new ProducerRecord<>(topic, Integer.toString(i), Integer.toString(i)));
+                producer.send(new ProducerRecord<>(topic, Integer.toString(i), "测试" + i));
             }
         }
     }

pom.xml

@@ -45,6 +45,7 @@
         <mysql.version>5.1.40</mysql.version>
         <mysql-binlog.version>0.21.0</mysql-binlog.version>
         <mssql-jdbc.version>8.2.0.jre8</mssql-jdbc.version>
+        <kafka.version>0.9.0.0</kafka.version>
         <json.version>20090211</json.version>
         <fastjson.version>1.2.75</fastjson.version>
         <junit.version>4.12</junit.version>
@@ -155,6 +156,12 @@
                 <version>${mysql-binlog.version}</version>
             </dependency>
 
+            <dependency>
+                <groupId>org.apache.kafka</groupId>
+                <artifactId>kafka-clients</artifactId>
+                <version>${kafka.version}</version>
+            </dependency>
+
             <dependency>
                 <groupId>junit</groupId>
                 <artifactId>junit</artifactId>