Skip to content

Commit 886284f

Browse files
authored
Fix Transport SASL configuration (#885)
1 parent 3049a65 commit 886284f

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

README.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -669,7 +669,7 @@ if err != nil {
669669
// it's generally best to create a few of these and share them across your
670670
// application.
671671
sharedTransport := &kafka.Transport{
672-
SASLMechanism: mechanism,
672+
SASL: mechanism,
673673
}
674674

675675
w := kafka.Writer{
@@ -692,7 +692,7 @@ if err != nil {
692692
// it's generally best to create a few of these and share them across your
693693
// application.
694694
sharedTransport := &kafka.Transport{
695-
SASLMechanism: mechanism,
695+
SASL: mechanism,
696696
}
697697

698698
client := &kafka.Client{

0 commit comments

Comments
 (0)