Does sarama-cluster supports kafka 2.0?
zzmg opened this issue · 2 comments
zzmg commented
Does sarama-cluster supports kafka 2.0?
zzmg commented
Error: kafka: error while consuming applog/2: kafka: error decoding packet: CRC didn't match expected 0x0 got 0xe38a6876
dim commented
@langzi-zmg you need to set the correct sarama.Config.Version when connecting to Kafka, nothing to do with sarama-cluster. Also, since IBM/sarama#1099 was merged and released, this library is officially deprecated.