Skip to content

Commit 41aea6b

Browse files
committed
remove kafka version parser
1 parent e880837 commit 41aea6b

File tree

1 file changed

+0
-3
lines changed

1 file changed

+0
-3
lines changed

sarama_subscriber.go

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -26,9 +26,6 @@ type SubscriberHandler struct {
2626
func NewSaramaSubscriber(args *Argument) (*SaramaSubscriberImpl, error) {
2727
config := sarama.NewConfig()
2828
config.ClientID = "kafka-cli"
29-
30-
kafkaVersion, _ := sarama.ParseKafkaVersion("2.1.1")
31-
config.Version = kafkaVersion
3229
config.Consumer.Return.Errors = true
3330

3431
if args.Auth {

0 commit comments

Comments
 (0)