diff --git a/labs/kafka/KafkaEFTest/Program.cs b/labs/kafka/KafkaEFTest/Program.cs
index df50b6bc..1f2b8b91 100644
--- a/labs/kafka/KafkaEFTest/Program.cs
+++ b/labs/kafka/KafkaEFTest/Program.cs
@@ -158,6 +158,8 @@ namespace KafkaEFTest
                     using (var cmd = conn.CreateCommand())
                     {
                         cmd.CommandTimeout = 60;
+                        //不需要update，只需要插入，主键相同的自动合并
+                        //可以delete，不建议delete，建议更新标志位
                         cmd.CommandText = $"insert into test (`id`,`value`,`number`) values ('{entity.Id}','{entity.Value}',{entity.Number})";
                         cmd.ExecuteNonQuery();
                     }