kafka git commit: KAFKA-6015; Fix NPE in RecordAccumulator after ProducerId reset

2017-10-06 Thread jgus
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

kafka git commit: KAFKA-6015; Fix NPE in RecordAccumulator after ProducerId reset

2017-10-06 Thread jgus
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