Taking another look at it this morning, it seems like we're attempting to process some ConsumerRecords for partitions that we don't have assigned. Is it possible? Like, if we do a rebalance but the consumer already had some records buffered?
If so, maybe the right thing to do is actually to just drop the records. [ Full content available at: https://github.com/apache/kafka/pull/5648 ] This message was relayed via gitbox.apache.org for [email protected]
