结构更改

byit-screen-computer/src/test/java/com/byit/TestProducer.java

 package com.byit;
 
+import com.byit.common.utils.GsonUtil;
 import org.apache.kafka.clients.producer.KafkaProducer;
+import org.apache.kafka.clients.producer.ProducerRecord;
 
 import java.util.Properties;
 
 public class TestProducer {
     public static final String broker_list = "10.0.10.136:9092,10.0.10.137:9092,10.0.10.138:9092";
-    public static final String topic = "student";  //kafka topic 需要和 flink 程序用同一个 topic
+    public static final String topic = "input";  //kafka topic 需要和 flink 程序用同一个 topic
 
     public static void writeToKafka() throws InterruptedException {
         Properties props = new Properties();
@@ -15,11 +17,11 @@ public class TestProducer {
         props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
         KafkaProducer producer = new KafkaProducer<String, String>(props);
 
-        for (int i = 1; i <= 10000; i++) {
-            /*Student student = new Student(i, "zhisheng" + i, "password" + i, 18 + i);
-            ProducerRecord record = new ProducerRecord<String, String>(topic, null, null, GsonUtil.toJson(student));
+        for (int i = 1; i <= 100; i++) {
+            String student = "{l_" + i + ": slae" + i + "}";
+            ProducerRecord record = new ProducerRecord<String, String>(topic, null, null, student);
             producer.send(record);
-            System.out.println("发送数据: " + GsonUtil.toJson(student));*/
+            System.out.println("发送数据: " + student);
         }
         producer.flush();
     }