Skip to content

Commit

Permalink
Fix code in example (#1201)
Browse files Browse the repository at this point in the history
  • Loading branch information
rouzier authored Oct 3, 2023
1 parent efe02d6 commit 4eabe8b
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions writer.go
Original file line number Diff line number Diff line change
Expand Up @@ -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,
// }
Expand All @@ -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
Expand Down

0 comments on commit 4eabe8b

Please sign in to comment.