Repository: kafka
Updated Branches:
refs/heads/1.0 ebeee3c8d -> aa1e4c235
KAFKA-6015; Fix NPE in RecordAccumulator after ProducerId reset
It is possible for batches with sequence numbers to be in the `deque` while at
the same time the in flight batches in the `TransactionManager` are removed
Repository: kafka
Updated Branches:
refs/heads/trunk 10cd98cc8 -> 105ab47ed
KAFKA-6015; Fix NPE in RecordAccumulator after ProducerId reset
It is possible for batches with sequence numbers to be in the `deque` while at
the same time the in flight batches in the `TransactionManager` are