Consumer Issue in decoding packet
harshitdx29 opened this issue · 1 comments
harshitdx29 commented
Hi I am creating a consumer using the following code:
brokersList := strings.Split(config.Config.KafkaConfig.Brokers, ",")
topicsList := strings.Split(config.Config.KafkaConfig.Topic, ",")
consumerGroup := config.Config.KafkaConfig.ConsumerGroup
bsmConfig := cluster.NewConfig()
bsmConfig.Consumer.Return.Errors = true
bsmConfig.Group.Return.Notifications = true
//bsmConfig.Consumer.Offsets.Initial = sarama.OffsetOldest
bsmConfig.Version = sarama.V0_10_1_0
consumer, err := cluster.NewConsumer(brokersList, consumerGroup, topicsList, bsmConfig)
I am getting the following error:
kafka: error while consuming topic_harshit/0: kafka: error decoding packet: CRC didn't match
dim commented
That sounds like a producer/protocol issue. Sorry, but sarama-cluster fully relies on https://github.com/Shopify/sarama for consuming messages, it doesn't do anything to them. It's something you may need to raise with them.