segmentio/kafka-go,版本适配进度太慢EOF, IBM/sarama真香~
记录一个BUG。
segmentio/kafka-go,版本适配进度太慢,kafka-go频繁报EOF,反复重连。
后来查了github readme,segmentio/kafka-go当前仅适配了:kafka-go
is currently tested with Kafka versions 0.10.1.0 to 2.7.1.
IBM/sarama真香,换成IBM/sarama后成功解决kafka高版本适配问题:
https://github.com/IBM/sarama