结构更改

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

@@ -17,8 +17,8 @@ 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 <= 100; i++) {
-            String student = "{l_" + i + ": slae" + i + "}";
+        for (int i = 1; i <= 20; i++) {
+            String student = "{l_" + (i % 10) + ": " + i + "}";
             ProducerRecord record = new ProducerRecord<String, String>(topic, null, null, student);
             producer.send(record);
             System.out.println("发送数据: " + student);