fix: update workbench test middleware config

README.md

@@ -54,7 +54,7 @@ IM_WORKBENCH_CONFIG=configs/workbench.local.json \
 go run ./cmd/workbench
 ```
 
-测试环境使用 `configs/workbench.test.json` 中的 SASL/SCRAM-SHA-512 配置。
+测试环境使用 `configs/workbench.test.json`，Kafka 为明文 PLAINTEXT 直连，不配置 SASL/TLS。
 
 事件体字段：
 

configs/workbench.test.json

@@ -1,10 +1,10 @@
 {
   "listen": ":6061",
   "mysql": {
-    "dsn": "root:oWxz*2=sb),ouW%p@tcp(64.118.137.182:53306)/tinode?parseTime=true&charset=utf8mb4,utf8&loc=Local"
+    "dsn": "root:oWxz*2=sb),ouW%p@tcp(mysql.118im.com:30306)/tinode?parseTime=true&charset=utf8mb4,utf8&loc=Local"
   },
   "redis": {
-    "addr": "64.118.137.182:56379",
+    "addr": "redis.118im.com:30637",
     "password": "HMTJzkm.h>Y+E9ep",
     "db": 0,
     "key_prefix": "im:"
@@ -12,12 +12,12 @@
   "kafka": {
     "enabled": true,
     "brokers": [
-      "64.118.137.182:9094"
+      "kafka.118im.com:30835"
     ],
     "topic": "im.workbench.event",
-    "username": "kafka-external",
+    "username": "",
-    "password": "gr58tNnlZOVGW3AmMbL2",
+    "password": "",
-    "sasl": "SCRAM-SHA-512",
+    "sasl": "",
     "client_id": "im_workbench_test"
   },
   "auth": {

internal/events/events.go

@@ -96,7 +96,6 @@ func (p *KafkaPublisher) Publish(ctx context.Context, event Event) error {
 		key = []byte(event.EventID)
 	}
 	return p.writer.WriteMessages(ctx, kafka.Message{
-		Topic: p.topic,
 		Key:   key,
 		Value: data,
 		Headers: []kafka.Header{