Skip to content

Commit 4eabe8b

Browse files
authored
Fix code in example (#1201)
1 parent efe02d6 commit 4eabe8b

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

writer.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@ import (
2929
//
3030
// // Construct a synchronous writer (the default mode).
3131
// w := &kafka.Writer{
32-
// Addr: Addr: kafka.TCP("localhost:9092", "localhost:9093", "localhost:9094"),
32+
// Addr: kafka.TCP("localhost:9092", "localhost:9093", "localhost:9094"),
3333
// Topic: "topic-A",
3434
// RequiredAcks: kafka.RequireAll,
3535
// }
@@ -55,7 +55,7 @@ import (
5555
// writer to receive notifications of messages being written to kafka:
5656
//
5757
// w := &kafka.Writer{
58-
// Addr: Addr: kafka.TCP("localhost:9092", "localhost:9093", "localhost:9094"),
58+
// Addr: kafka.TCP("localhost:9092", "localhost:9093", "localhost:9094"),
5959
// Topic: "topic-A",
6060
// RequiredAcks: kafka.RequireAll,
6161
// Async: true, // make the writer asynchronous

0 commit comments

Comments
 (0)