From b7424d7b2f445d06710a7de077fcb935e0094436 Mon Sep 17 00:00:00 2001 From: crusader Date: Sun, 1 Apr 2018 19:08:46 +0900 Subject: [PATCH] ing --- external/kafka/kafka.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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{}, }) }