[jira] [Created] (KAFKA-1064) Bad pom.xml definition

2013-09-23 Thread Ben Manes (JIRA)
Ben Manes created KAFKA-1064: Summary: Bad pom.xml definition Key: KAFKA-1064 URL: https://issues.apache.org/jira/browse/KAFKA-1064 Project: Kafka Issue Type: Bug Affects Versions: 0.8

[jira] [Updated] (KAFKA-946) Kafka Hadoop Consumer fails when verifying message checksum

2013-09-23 Thread Sam Meder (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sam Meder updated KAFKA-946: Attachment: hadoop_consumer_1.patch > Kafka Hadoop Consumer fails when verifying message checksum >

[jira] [Commented] (KAFKA-946) Kafka Hadoop Consumer fails when verifying message checksum

2013-09-23 Thread Sam Meder (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13775988#comment-13775988 ] Sam Meder commented on KAFKA-946: - Rebased patch attached. > Kafka Hadoop

[jira] [Updated] (KAFKA-946) Kafka Hadoop Consumer fails when verifying message checksum

2013-09-23 Thread Sam Meder (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sam Meder updated KAFKA-946: Attachment: (was: hadoop_consumer.patch) > Kafka Hadoop Consumer fails when verifying message checks

Re: zkclient dies after UnknownHostException in zk reconnect

2013-09-23 Thread Sam Meder
For what it is worth I am currently looking into a problem that sounds suspiciously related. We're seeing no node exceptions for the consumer node during rebalance: Caused by: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/es_consumer/ids/es_consu

Re: zkclient dies after UnknownHostException in zk reconnect

2013-09-23 Thread Neha Narkhede
Interesting. I haven't had the chance to dive into the zkclient codebase to understand the root cause yet, but since you mentioned this can cause ephemeral node loss, I am curious to know how you detected the ephemeral node loss. Did the Kafka consumer not respond to rebalance events or did the ser

[jira] [Updated] (KAFKA-1063) run log cleanup at startup

2013-09-23 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1063: - Fix Version/s: 0.8 > run log cleanup at startup > -- > >

[jira] [Commented] (KAFKA-946) Kafka Hadoop Consumer fails when verifying message checksum

2013-09-23 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13774707#comment-13774707 ] Jun Rao commented on KAFKA-946: --- Sorry for not looking at this earlier. I think that we can i

[jira] [Closed] (KAFKA-975) Leader not local for partition when partition is leader (kafka.common.NotLeaderForPartitionException)

2013-09-23 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao closed KAFKA-975. - > Leader not local for partition when partition is leader > (kafka.common.NotLeaderForPartitionException) > -

[jira] [Resolved] (KAFKA-975) Leader not local for partition when partition is leader (kafka.common.NotLeaderForPartitionException)

2013-09-23 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-975. --- Resolution: Not A Problem Assignee: (was: Neha Narkhede) Carl, thanks for the update. Could you mind

[jira] Subscription: outstanding kafka patches

2013-09-23 Thread jira
Issue Subscription Filter: outstanding kafka patches (67 issues) The list of outstanding kafka patches Subscriber: kafka-mailing-list Key Summary KAFKA-1049 Encoder implementations are required to provide an undocumented constructor. https://issues.apache.org/jira/bro

[jira] [Commented] (KAFKA-1008) Unmap before resizing

2013-09-23 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13774698#comment-13774698 ] Jun Rao commented on KAFKA-1008: Sorry, I missed that comment. +1 on v8.

[jira] [Created] (KAFKA-1063) run log cleanup at startup

2013-09-23 Thread paul mackles (JIRA)
paul mackles created KAFKA-1063: --- Summary: run log cleanup at startup Key: KAFKA-1063 URL: https://issues.apache.org/jira/browse/KAFKA-1063 Project: Kafka Issue Type: Bug Components:

[jira] [Commented] (KAFKA-1008) Unmap before resizing

2013-09-23 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13774684#comment-13774684 ] Jay Kreps commented on KAFKA-1008: -- Sriram had the same comment. It is possible to reason

[jira] [Commented] (KAFKA-1008) Unmap before resizing

2013-09-23 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13774619#comment-13774619 ] Jun Rao commented on KAFKA-1008: Thanks for patch v8. Just one more comment. 80. OffsetIn

zkclient dies after UnknownHostException in zk reconnect

2013-09-23 Thread Anatoly Fayngelerin
Hi Everyone, I've run into the following issue with the Kafka server. The zkclient lib seems to die silently if there is an UnknownHostException(or any IOException) while reconnecting the ZK session. I've filed a bug about this with the zkclient lib(https://github.com/sgroschupf/zkclient/issues/23