bsm/sarama-cluster

Seeing lots of consumer errors with Sarama 1.17.0

jpiper opened this issue · 3 comments

I'm running Sarama 1.17.0 and sarama-cluster 2.1.14 and Kafka 1.1.0

I was previously running Sarama 1.16.0 and sarama-cluster 2.1.13 and had no issues, but when I upgraded, I keep seeing the following...

2018/08/16 14:29:50 Consumer error: kafka server: The provided member is not known in the current generation.
2018/08/16 14:29:50 Rebalanced: &{Type:rebalance error Claimed:map[] Released:map[] Current:map[]}
2018/08/16 14:29:50 Rebalanced: &{Type:rebalance start Claimed:map[] Released:map[] Current:map[]}
2018/08/16 14:29:53 Consumer error: kafka: invalid configuration (That topic/partition is already being consumed)
2018/08/16 14:29:53 Rebalanced: &{Type:rebalance error Claimed:map[] Released:map[] Current:map[]}
2018/08/16 14:29:53 Rebalanced: &{Type:rebalance start Claimed:map[] Released:map[] Current:map[]}
2018/08/16 14:29:53 Consumer error: kafka server: The provided member is not known in the current generation.
2018/08/16 14:29:53 Rebalanced: &{Type:rebalance error Claimed:map[] Released:map[] Current:map[]}
2018/08/16 14:29:53 Rebalanced: &{Type:rebalance start Claimed:map[] Released:map[] Current:map[]}
2018/08/16 14:29:56 Consumer error: kafka: invalid configuration (That topic/partition is already being consumed)
2018/08/16 14:29:56 Rebalanced: &{Type:rebalance error Claimed:map[] Released:map[] Current:map[]}
2018/08/16 14:29:56 Rebalanced: &{Type:rebalance start Claimed:map[] Released:map[] Current:map[]}

Any idea what could be causing this?

We've seen it as well,
looks like it's related to #258

if I roll back before that PR to d985926 (sarama-cluster v2.1.13-7-gd985926) I don't have any issues, so that PR must be to blame

dim commented

reverting ...