From 9c3c832d5b760b71b3fadaae8cf0b567b993abe2 Mon Sep 17 00:00:00 2001 From: James Rouzier Date: Tue, 3 Oct 2023 15:15:12 +0000 Subject: [PATCH] Fix code in example --- writer.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/writer.go b/writer.go index c37d8e04..b74467be 100644 --- a/writer.go +++ b/writer.go @@ -29,7 +29,7 @@ import ( // // // Construct a synchronous writer (the default mode). // w := &kafka.Writer{ -// Addr: Addr: kafka.TCP("localhost:9092", "localhost:9093", "localhost:9094"), +// Addr: kafka.TCP("localhost:9092", "localhost:9093", "localhost:9094"), // Topic: "topic-A", // RequiredAcks: kafka.RequireAll, // } @@ -55,7 +55,7 @@ import ( // writer to receive notifications of messages being written to kafka: // // w := &kafka.Writer{ -// Addr: Addr: kafka.TCP("localhost:9092", "localhost:9093", "localhost:9094"), +// Addr: kafka.TCP("localhost:9092", "localhost:9093", "localhost:9094"), // Topic: "topic-A", // RequiredAcks: kafka.RequireAll, // Async: true, // make the writer asynchronous