tree 5d25907861bf4ad35438a6df8b72f70c6007d38e
parent a7ab9cb83d2c47d980b0b9f6b702e01bd1cf4139
author Tim Brooks <tim@uncontended.net> 1473737281 -0700
committer Jason Gustafson <jason@confluent.io> 1473737281 -0700

KAFKA-2311; Make KafkaConsumer's ensureNotClosed method thread-safe

Here is the patch on github ijuma.

Acquiring the consumer lock (the single thread access controls) requires that the consumer be open. I changed the closed variable to be volatile so that another thread's writes will visible to the reading thread.

Additionally, there was an additional check if the consumer was closed after the lock was acquired. This check is no longer necessary.

This is my original work and I license it to the project under the project's open source license.

Author: Tim Brooks <tim@uncontended.net>

Reviewers: Jason Gustafson <jason@confluent.io>

Closes #1637 from tbrooks8/KAFKA-2311