From c1f7ce2b85905a9ec3879a906f326710a615f6dc Mon Sep 17 00:00:00 2001 From: yumaojun03 <719118794@qq.com> Date: Sun, 20 Jul 2025 09:10:36 +0800 Subject: [PATCH] update kafka --- skills/kafka/kafka_test.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/skills/kafka/kafka_test.go b/skills/kafka/kafka_test.go index 88c3c2f..1151081 100644 --- 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 })