测试类格式

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

@@ -17,11 +17,12 @@ 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 <= 20; i++) {
-            String student = "{l_" + (i % 10) + ": " + i + "}";
+        for (int i = 1; i <= 200; i++) {
+            String student = "{name:l_" + (i % 10) + ",sale: " + i + "}";
             ProducerRecord record = new ProducerRecord<String, String>(topic, null, null, student);
             producer.send(record);
             System.out.println("发送数据: " + student);
+            Thread.sleep(1000);
         }
         producer.flush();
     }