Skip to content

Commit 972c82f

Browse files
committed
fix typo
1 parent 712d932 commit 972c82f

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

cmd/kafka-cli/main.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,7 @@ func main() {
3737
os.Exit(1)
3838
}
3939

40-
subsriber, err := kafka.NewKafkaGoSubscriber(args.Topic, args.Brokers...)
40+
subscriber, err := kafka.NewKafkaGoSubscriber(args.Topic, args.Brokers...)
4141
if err != nil {
4242
fmt.Println("error : ", err)
4343

@@ -51,7 +51,7 @@ func main() {
5151
// os.Exit(1)
5252
// }
5353

54-
// subsriber, err := kafka.NewSaramaSubscriber(args.Brokers...)
54+
// subscriber, err := kafka.NewSaramaSubscriber(args.Brokers...)
5555
// if err != nil {
5656
// fmt.Println("error : ", err)
5757

@@ -60,7 +60,7 @@ func main() {
6060

6161
runner := kafka.Runner{
6262
Publisher: publisher,
63-
Subscriber: subsriber,
63+
Subscriber: subscriber,
6464
Argument: args,
6565
}
6666

0 commit comments

Comments
 (0)