update kafka

2025-07-20 09:10:36 +08:00 · 2025-07-20 09:10:36 +08:00 · c1f7ce2b85
commit c1f7ce2b85
parent 87bda92fac
1 changed files with 1 additions and 1 deletions
--- a/skills/kafka/kafka_test.go
+++ b/skills/kafka/kafka_test.go
@ -116,7 +116,7 @@ func TestReadMessage(t *testing.T) {
 		GroupID: "devcloud-go18-audit",
 		// 可以指定Partition消费消息
 		// Partition: 0,
-		Topic:    "audit_go18",
+		Topic:    "task_run_events",
 		MinBytes: 10e3, // 10KB
 		MaxBytes: 10e6, // 10MB
 	})