From c85320656a66341d26fb5315384795cdca273e48 Mon Sep 17 00:00:00 2001 From: Jaewook Lee Date: Mon, 10 Jun 2024 22:20:26 +0900 Subject: [PATCH] Chore: change broker addr --- streamer_test.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/streamer_test.go b/streamer_test.go index e80052a..6da33a5 100644 --- a/streamer_test.go +++ b/streamer_test.go @@ -8,7 +8,7 @@ import ( "testing" ) -var brokers = []string{"localhost:9092"} +var brokers = []string{"localhost:9093"} var topic = qstreamer.Topic("test", 1) func TestTopicStreamer_NewTopicStreamer(t *testing.T) {