Skip to content

KAFKA-6704: InvalidStateStoreException from IQ when StreamThread closes store#4801

Merged
guozhangwang merged 7 commits into
apache:trunkfrom
bbejeck:KAFKA_6704_invalid_state_store_error_possible_from_iq
Jun 5, 2018
Merged

KAFKA-6704: InvalidStateStoreException from IQ when StreamThread closes store#4801
guozhangwang merged 7 commits into
apache:trunkfrom
bbejeck:KAFKA_6704_invalid_state_store_error_possible_from_iq

added synchronized to hasNext and next

01be095
Select commit
Loading
Failed to load commit list.

Workflow runs completed with no jobs