fix(go): require kafka write acknowledgements

2026-07-02 13:06:18 +08:00
parent ba5a28e636
commit 924903feb4
2 changed files with 28 additions and 0 deletions
--- a/go/vehicle-gateway/internal/eventbus/kafka_sink.go
+++ b/go/vehicle-gateway/internal/eventbus/kafka_sink.go
@@ -41,6 +41,8 @@ func NewKafkaSink(cfg KafkaConfig) (*KafkaSink, error) {
 		Addr:                   kafka.TCP(cfg.Brokers...),
 		Balancer:               &kafka.Hash{},
 		AllowAutoTopicCreation: false,
+		RequiredAcks:           kafka.RequireAll,
+		Async:                  false,
 	}, cfg), nil
 }