diff --git a/external/kafka/kafka.go b/external/kafka/kafka.go index 480d344..02a90b3 100644 --- a/external/kafka/kafka.go +++ b/external/kafka/kafka.go @@ -12,7 +12,7 @@ var ( func ExternalInit() { kafkaWriter = kafka.NewWriter(kafka.WriterConfig{ Brokers: []string{"192.168.1.50:9092"}, - Topic: "topic-overflow-probe-metric", + Topic: "overflow-metric-topic", Balancer: &kafka.LeastBytes{}, }) }