[jira] [Assigned] (KAFKA-3812) State store locking is incorrect

2016-07-17 Thread Damian Guy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-3812: - Assignee: Damian Guy (was: Eno Thereska) > State store locking is incorrect > --

[GitHub] kafka pull request #1628: KAFKA-3812 State store locking is incorrect

2016-07-17 Thread dguy
GitHub user dguy opened a pull request: https://github.com/apache/kafka/pull/1628 KAFKA-3812 State store locking is incorrect Move all state directory creation/locking/unlocking/cleaning to a single class. Don't release the channel until the lock is released. Refactor code to make

[jira] [Commented] (KAFKA-3812) State store locking is incorrect

2016-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15381412#comment-15381412 ] ASF GitHub Bot commented on KAFKA-3812: --- GitHub user dguy opened a pull request:

[jira] [Commented] (KAFKA-3693) Race condition between highwatermark-checkpoint thread and handleLeaderAndIsrRequest at broker start-up

2016-07-17 Thread Alexey Ozeritskiy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15381452#comment-15381452 ] Alexey Ozeritskiy commented on KAFKA-3693: -- It seems this issue is related to KAF

[jira] [Updated] (KAFKA-3693) Lost highwatermark at broker start-up

2016-07-17 Thread Maysam Yabandeh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maysam Yabandeh updated KAFKA-3693: --- Summary: Lost highwatermark at broker start-up (was: Race condition between highwatermark-che

[jira] [Commented] (KAFKA-3693) Lost highwatermark at broker start-up

2016-07-17 Thread Maysam Yabandeh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15381457#comment-15381457 ] Maysam Yabandeh commented on KAFKA-3693: Thanks [~aozeritsky]. I linked the issue.

[jira] [Comment Edited] (KAFKA-3969) kafka.admin.ConsumerGroupCommand doesn't show consumer groups

2016-07-17 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15381500#comment-15381500 ] Vahid Hashemian edited comment on KAFKA-3969 at 7/17/16 8:10 PM: ---

[jira] [Commented] (KAFKA-3969) kafka.admin.ConsumerGroupCommand doesn't show consumer groups

2016-07-17 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15381500#comment-15381500 ] Vahid Hashemian commented on KAFKA-3969: [~dieter_be]] Is the consumer you're runn

[jira] [Commented] (KAFKA-3969) kafka.admin.ConsumerGroupCommand doesn't show consumer groups

2016-07-17 Thread Dieter Plaetinck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15381538#comment-15381538 ] Dieter Plaetinck commented on KAFKA-3969: - not sure. how do I tell? I do know i us

[jira] [Commented] (KAFKA-3102) Kafka server unable to connect to zookeeper

2016-07-17 Thread Sam Liu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15381653#comment-15381653 ] Sam Liu commented on KAFKA-3102: Thanks Manikuma. That helps > Kafka server unable to con

Re: [DISCUSS] Client Side Auto Topic Creation

2016-07-17 Thread Jun Rao
Bosco, Currently, if acl is enabled, auto topic creation will succeed if the client has the CREATE permission. Thanks, Jun On Mon, Jul 11, 2016 at 6:26 PM, Don Bosco Durai wrote: > Jun, my understanding is, currently if ACLs are enabled, then auto topic > creation is disabled. Is this going t

Re: [DISCUSS] KIP-66 Kafka Connect Transformers for messages

2016-07-17 Thread Jun Rao
Does the transformation need to be 1-to-1? For example, some users model each Kafka message as schema + a batch of binary records. When using a sink connector to push the Kafka data to a sink, if would be useful if the transformer can convert each Kafka message to multiple records. Thanks, Jun O

Re: [DISCUSS] Client Side Auto Topic Creation

2016-07-17 Thread Don Bosco Durai
Jun, thanks. I will check again. Regards Bosco On 7/17/16, 9:36 PM, "Jun Rao" wrote: Bosco, Currently, if acl is enabled, auto topic creation will succeed if the client has the CREATE permission. Thanks, Jun On Mon, Jul 11, 2016 at 6:26 PM, Don Bosc