Does sarama-cluster supports kafka 2.0?

bsm / sarama-cluster

Cluster extensions for Sarama, the Go client library for Apache Kafka 0.9 [DEPRECATED]

MIT License

1.01k stars 222 forks source link

Does sarama-cluster supports kafka 2.0? #279

Closed zzmg closed 6 years ago

zzmg commented 6 years ago

Error: kafka: error while consuming applog/2: kafka: error decoding packet: CRC didn't match expected 0x0 got 0xe38a6876

dim commented 6 years ago

@langzi-zmg you need to set the correct sarama.Config.Version when connecting to Kafka, nothing to do with sarama-cluster. Also, since https://github.com/Shopify/sarama/pull/1099 was merged and released, this library is officially deprecated.