增加 spring boot kafka 示例

Author: YunaiV

lab-03/lab-03-kafka-demo-batch/src/main/java/cn/iocoder/springboot/lab03/kafkademo/producer/Demo02Producer.java

@@ -15,7 +15,7 @@ public class Demo02Producer {
     private KafkaTemplate<Object, Object> kafkaTemplate;
 
     public ListenableFuture<SendResult<Object, Object>> asyncSend(Integer id) {
-        // 创建 Demo01Message 消息
+        // 创建 Demo02Message 消息
         Demo02Message message = new Demo02Message();
         message.setId(id);
         // 异步发送消息

lab-03/lab-03-kafka-demo-batch/src/test/java/cn/iocoder/springboot/lab03/kafkademo/producer/Demo02ProducerTest.java

@@ -25,6 +25,7 @@ public class Demo02ProducerTest {
     @Test
     public void testASyncSend() throws InterruptedException {
         logger.info("[testASyncSend][开始执行]");
+
         for (int i = 0; i < 3; i++) {
             int id = (int) (System.currentTimeMillis() / 1000);
             producer.asyncSend(id).addCallback(new ListenableFutureCallback<SendResult<Object, Object>>() {