You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@kafka.apache.org by "Tim Brooks (JIRA)" <ji...@apache.org> on 2016/07/19 16:47:20 UTC

[jira] [Commented] (KAFKA-2311) Consumer's ensureNotClosed method not thread safe

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

Tim Brooks commented on KAFKA-2311:
-----------------------------------

Yes. Sorry, I had not been checking in with development recently. And I must of missed the email for your comment.

I just checked on "develop" and it seems like it is not fixed yet. I'll submit a PR on github today.

> 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.10.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)