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
[
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
[
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
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:
[
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.
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
[
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)
> -
[
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
[
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
[
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
> --
>
>
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
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
[
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
[
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
[
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
>
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
16 matches
Mail list logo
