[ 
https://issues.apache.org/jira/browse/KAFKA-2311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15062314#comment-15062314
 ] 

Ismael Juma commented on KAFKA-2311:
------------------------------------

Looks like this never made it in. Would you be willing to create a pull request 
with the change (as described here http://kafka.apache.org/contributing.html)?

> Consumer's ensureNotClosed method not thread safe
> -------------------------------------------------
>
>                 Key: KAFKA-2311
>                 URL: https://issues.apache.org/jira/browse/KAFKA-2311
>             Project: Kafka
>          Issue Type: Bug
>          Components: clients
>            Reporter: Tim Brooks
>            Assignee: Tim Brooks
>             Fix For: 0.9.1.0
>
>         Attachments: KAFKA-2311.patch, KAFKA-2311.patch
>
>
> When a call is to the consumer is made, the first check is to see that the 
> consumer is not closed. This variable is not volatile so there is no 
> guarantee previous stores will be visible before a read.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to