Build failed in Jenkins: kafka_system_tests #137

See -- [...truncated 39 lines...] :contrib:clean :copycat:clean :core:clean :examples:clean :log4j-appender:clean :streams:clean :tools:clean :contrib:hadoop-consumer:clean :contrib:hadoop-producer:cl

[jira] [Created] (KAFKA-2761) Enable passing regex via whitelist for new-consumer in ConsoleConsumer

Ashish K Singh created KAFKA-2761: - Summary: Enable passing regex via whitelist for new-consumer in ConsoleConsumer Key: KAFKA-2761 URL: https://issues.apache.org/jira/browse/KAFKA-2761 Project: Kafka

[jira] [Commented] (KAFKA-2760) Clean up interface of AdminClient.describeConsumerGroup(groupId

[ https://issues.apache.org/jira/browse/KAFKA-2760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14993201#comment-14993201 ] ASF GitHub Bot commented on KAFKA-2760: --- GitHub user SinghAsDev opened a pull reques

[GitHub] kafka pull request: KAFKA-2760: Clean up interface of AdminClient....

GitHub user SinghAsDev opened a pull request: https://github.com/apache/kafka/pull/442 KAFKA-2760: Clean up interface of AdminClient.describeConsumerGroup(g… …roupId) You can merge this pull request into a Git repository by running: $ git pull https://github.com/SinghAsDev/

[jira] [Updated] (KAFKA-2760) Clean up interface of AdminClient.describeConsumerGroup(groupId

[ https://issues.apache.org/jira/browse/KAFKA-2760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-2760: -- Summary: Clean up interface of AdminClient.describeConsumerGroup(groupId (was: Clean up interfa

[jira] [Updated] (KAFKA-2760) Clean up interface of AdminClient..describeConsumerGroup(groupId

[ https://issues.apache.org/jira/browse/KAFKA-2760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-2760: -- Summary: Clean up interface of AdminClient..describeConsumerGroup(groupId (was: Clean up interf

[jira] [Created] (KAFKA-2760) Clean up interface of AdminClient..describeConsumerGroup(groupId)

Ashish K Singh created KAFKA-2760: - Summary: Clean up interface of AdminClient..describeConsumerGroup(groupId) Key: KAFKA-2760 URL: https://issues.apache.org/jira/browse/KAFKA-2760 Project: Kafka

[jira] [Commented] (KAFKA-2723) Standardize new consumer exceptions

[ https://issues.apache.org/jira/browse/KAFKA-2723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14993191#comment-14993191 ] ASF GitHub Bot commented on KAFKA-2723: --- GitHub user hachikuji opened a pull request

[GitHub] kafka pull request: KAFKA-2723: new consumer exception cleanup

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/441 KAFKA-2723: new consumer exception cleanup You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka K2723 Alternatively you can review

Build failed in Jenkins: kafka-trunk-jdk8 #107

See Changes: [cshapi] HOTFIX: unsubscribe does not clear user assignment properly -- [...truncated 3974 lines...] kafka.log.BrokerCompressionTest > testBrokerSideCompression[0] PASSED kafka.log

Jenkins build is back to normal : kafka-trunk-jdk7 #768

See

[GitHub] kafka pull request: HOTFIX: unsubscribe does not clear user assign...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/439 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabl

Build failed in Jenkins: kafka-trunk-jdk8 #106

See Changes: [cshapi] KAFKA-2702: ConfigDef toHtmlTable() sorts in a way that is a bit conf… [cshapi] KAFKA-2490: support new consumer in ConsumerGroupCommand -- [...truncated 4760 lines...]

[GitHub] kafka pull request: Do not merge: Multi-consumer integration tests...

GitHub user apovzner opened a pull request: https://github.com/apache/kafka/pull/440 Do not merge: Multi-consumer integration tests for consumer group subsribe and timeouts and corresponding fixes A subset of changes for CPKAFKA-81 for initial review. -- Refactored multi-co

[GitHub] kafka pull request: HOTFIX: unsubscribe does not clear user assign...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/439 HOTFIX: unsubscribe does not clear user assignment properly You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka unsubscribe-hotfix

[jira] [Commented] (KAFKA-2759) Mirror maker can leave gaps of missing messages if the process dies after a partition is reset and before the first offset commit

[ https://issues.apache.org/jira/browse/KAFKA-2759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14993055#comment-14993055 ] Ewen Cheslack-Postava commented on KAFKA-2759: -- [~becket_qin] Yes, that would

[jira] [Commented] (KAFKA-1215) Rack-Aware replica assignment option

[ https://issues.apache.org/jira/browse/KAFKA-1215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14993035#comment-14993035 ] Vidhya Arvind commented on KAFKA-1215: -- Is there anyway this patch can be part of 0.9

[jira] [Resolved] (KAFKA-2490) support new consumer in ConsumerGroupCommand

[ https://issues.apache.org/jira/browse/KAFKA-2490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-2490. - Resolution: Fixed Issue resolved by pull request 299 [https://github.com/apache/kafka/pull/299] >

[jira] [Commented] (KAFKA-2490) support new consumer in ConsumerGroupCommand

[ https://issues.apache.org/jira/browse/KAFKA-2490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992988#comment-14992988 ] ASF GitHub Bot commented on KAFKA-2490: --- Github user asfgit closed the pull request

[GitHub] kafka pull request: KAFKA-2490: support new consumer in ConsumerGr...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/299 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabl

Build failed in Jenkins: kafka-trunk-jdk7 #767

See Changes: [cshapi] KAFKA-2702: ConfigDef toHtmlTable() sorts in a way that is a bit conf… -- [...truncated 102 lines...] ^

Build failed in Jenkins: kafka-trunk-jdk7 #766

See Changes: [cshapi] KAFKA-2745: Update JavaDoc for new / updated consumer APIs -- [...truncated 5501 lines...] kafka.log.BrokerCompressionTest > testBrokerSideCompression[0] PASSED kafka.log.

[jira] [Commented] (KAFKA-2759) Mirror maker can leave gaps of missing messages if the process dies after a partition is reset and before the first offset commit

[ https://issues.apache.org/jira/browse/KAFKA-2759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992967#comment-14992967 ] Jiangjie Qin commented on KAFKA-2759: - [~ewencp] Would it be simpler we just set the a

[jira] [Updated] (KAFKA-2702) ConfigDef toHtmlTable() sorts in a way that is a bit confusing

[ https://issues.apache.org/jira/browse/KAFKA-2702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2702: Resolution: Fixed Fix Version/s: 0.9.0.0 Status: Resolved (was: Patch Available)

[jira] [Commented] (KAFKA-2702) ConfigDef toHtmlTable() sorts in a way that is a bit confusing

[ https://issues.apache.org/jira/browse/KAFKA-2702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992957#comment-14992957 ] ASF GitHub Bot commented on KAFKA-2702: --- Github user asfgit closed the pull request

[GitHub] kafka pull request: KAFKA-2702: ConfigDef toHtmlTable() sorts in a...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/379 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabl

Re: Replication Broken between Kafka 0.8.2.1 and 0.9 (trunk)

Thanks for the contribution Matt! On Thu, Nov 5, 2015 at 4:21 PM, Matthew Bruce wrote: > Hi Grant, > > Creating a patch for this issue actually wasn't a whole lot of work. I've > uploaded one to the JIRA ticket. > > Thanks, > Matt > > -Original Message- > From: Matthew Bruce > Sent: Thu

[jira] [Updated] (KAFKA-2759) Mirror maker can leave gaps of missing messages if the process dies after a partition is reset and before the first offset commit

[ https://issues.apache.org/jira/browse/KAFKA-2759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2759: - Description: Based on investigation of KAFKA-2747. When mirror maker first starts

[jira] [Created] (KAFKA-2759) Mirror maker can leave gaps of missing messages if the process dies after a partition is reset and before the first offset commit

Ewen Cheslack-Postava created KAFKA-2759: Summary: Mirror maker can leave gaps of missing messages if the process dies after a partition is reset and before the first offset commit Key: KAFKA-2759 URL: htt

[jira] [Created] (KAFKA-2758) Improve Offset Commit Behavior

Guozhang Wang created KAFKA-2758: Summary: Improve Offset Commit Behavior Key: KAFKA-2758 URL: https://issues.apache.org/jira/browse/KAFKA-2758 Project: Kafka Issue Type: Sub-task

Build failed in Jenkins: kafka-trunk-jdk8 #105

See Changes: [cshapi] KAFKA-2745: Update JavaDoc for new / updated consumer APIs -- [...truncated 135 lines...]

Build failed in Jenkins: kafka-trunk-jdk8 #104

See Changes: [wangguoz] MINOR: follow-up KAFKA-2730 to use two tags for broker id and fetcher id [wangguoz] KAFKA-2756: Use request version Id instead of latest version Id to parse -- [...trun

[jira] [Resolved] (KAFKA-2745) Update JavaDoc for the new / updated APIs

[ https://issues.apache.org/jira/browse/KAFKA-2745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-2745. - Resolution: Fixed Issue resolved by pull request 425 [https://github.com/apache/kafka/pull/425] >

[jira] [Commented] (KAFKA-2745) Update JavaDoc for the new / updated APIs

[ https://issues.apache.org/jira/browse/KAFKA-2745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992804#comment-14992804 ] ASF GitHub Bot commented on KAFKA-2745: --- Github user asfgit closed the pull request

[GitHub] kafka pull request: KAFKA-2745: Update JavaDoc for new / updated c...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/425 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabl

Build failed in Jenkins: kafka-trunk-jdk7 #765

See Changes: [wangguoz] MINOR: follow-up KAFKA-2730 to use two tags for broker id and fetcher id [wangguoz] KAFKA-2756: Use request version Id instead of latest version Id to parse -- Started

[jira] [Commented] (KAFKA-2751) Documentation for retention.ms is confusing

[ https://issues.apache.org/jira/browse/KAFKA-2751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992772#comment-14992772 ] Dong Lin commented on KAFKA-2751: - [~gwenshap] Ah I forgot that patch. Thanks for letting

[jira] [Resolved] (KAFKA-2751) Documentation for retention.ms is confusing

[ https://issues.apache.org/jira/browse/KAFKA-2751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-2751. - Resolution: Won't Fix > Documentation for retention.ms is confusing >

[jira] [Commented] (KAFKA-2751) Documentation for retention.ms is confusing

[ https://issues.apache.org/jira/browse/KAFKA-2751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992771#comment-14992771 ] ASF GitHub Bot commented on KAFKA-2751: --- Github user lindong28 closed the pull reque

[GitHub] kafka pull request: MINOR: KAFKA-2751 Improve documentation for lo...

Github user lindong28 closed the pull request at: https://github.com/apache/kafka/pull/437 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is en

[jira] [Commented] (KAFKA-2756) Replication Broken between Kafka 0.8.2.1 and 0.9 - NetworkClient.java uses wrong protocol version

[ https://issues.apache.org/jira/browse/KAFKA-2756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992727#comment-14992727 ] ASF GitHub Bot commented on KAFKA-2756: --- Github user asfgit closed the pull request

[jira] [Updated] (KAFKA-2756) Replication Broken between Kafka 0.8.2.1 and 0.9 - NetworkClient.java uses wrong protocol version

[ https://issues.apache.org/jira/browse/KAFKA-2756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2756: - Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

[GitHub] kafka pull request: KAFKA-2756: Use request version Id instead of ...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/438 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabl

[jira] [Commented] (KAFKA-2730) partition-reassignment tool stops working due to error in registerMetric

[ https://issues.apache.org/jira/browse/KAFKA-2730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992719#comment-14992719 ] ASF GitHub Bot commented on KAFKA-2730: --- Github user asfgit closed the pull request

[GitHub] kafka pull request: MINOR: follow-up KAFKA-2730 to use two tags fo...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/434 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabl

[jira] [Updated] (KAFKA-2756) Replication Broken between Kafka 0.8.2.1 and 0.9 - NetworkClient.java uses wrong protocol version

[ https://issues.apache.org/jira/browse/KAFKA-2756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2756: Priority: Blocker (was: Major) > Replication Broken between Kafka 0.8.2.1 and 0.9 - NetworkClient.j

Kafka retention anomaly when restoring a broker

TL;DR broker replication should preserve file create time. My colleagues and I stumbled on an interesting issue in production. We use a time based retention policy instead of a size based policy and this normally works great (60 hours retention). A few days ago we rebuilt a broker (os reinstall)

[jira] [Commented] (KAFKA-2756) Replication Broken between Kafka 0.8.2.1 and 0.9 - NetworkClient.java uses wrong protocol version

[ https://issues.apache.org/jira/browse/KAFKA-2756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992705#comment-14992705 ] ASF GitHub Bot commented on KAFKA-2756: --- GitHub user guozhangwang opened a pull requ

[GitHub] kafka pull request: KAFKA-2756: Use request version Id instead of ...

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/438 KAFKA-2756: Use request version Id instead of latest version Id to parse the corresponding response. You can merge this pull request into a Git repository by running: $ git pull https://g

[jira] [Commented] (KAFKA-2751) Documentation for retention.ms is confusing

[ https://issues.apache.org/jira/browse/KAFKA-2751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992686#comment-14992686 ] Gwen Shapira commented on KAFKA-2751: - [~lindong], in 0.9 the configuration docs will

[jira] [Commented] (KAFKA-2756) Replication Broken between Kafka 0.8.2.1 and 0.9 - NetworkClient.java uses wrong protocol version

[ https://issues.apache.org/jira/browse/KAFKA-2756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992681#comment-14992681 ] Guozhang Wang commented on KAFKA-2756: -- Thanks for the patch [~mbr...@blackberry.com]

[jira] [Updated] (KAFKA-2756) Replication Broken between Kafka 0.8.2.1 and 0.9 - NetworkClient.java uses wrong protocol version

[ https://issues.apache.org/jira/browse/KAFKA-2756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2756: - Assignee: Matthew Bruce (was: Guozhang Wang) > Replication Broken between Kafka 0.8.2.1 and 0.9 -

[jira] [Commented] (KAFKA-2751) Documentation for retention.ms is confusing

[ https://issues.apache.org/jira/browse/KAFKA-2751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992651#comment-14992651 ] ASF GitHub Bot commented on KAFKA-2751: --- GitHub user lindong28 opened a pull request

[GitHub] kafka pull request: MINOR: KAFKA-2751 Improve documentation for lo...

GitHub user lindong28 opened a pull request: https://github.com/apache/kafka/pull/437 MINOR: KAFKA-2751 Improve documentation for log.retention.ms You can merge this pull request into a Git repository by running: $ git pull https://github.com/lindong28/kafka KAFKA-2751 Altern

[jira] [Assigned] (KAFKA-2751) Documentation for retention.ms is confusing

[ https://issues.apache.org/jira/browse/KAFKA-2751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned KAFKA-2751: --- Assignee: Dong Lin > Documentation for retention.ms is confusing > --

Build failed in Jenkins: kafka-trunk-jdk7 #764

See Changes: [wangguoz] KAFKA-2755: Suspicious reference forwarding cause NPE on [wangguoz] KAFKA-2735: BrokerEndPoint should support uppercase hostnames. -- Started by an SCM change [EnvInject]

RE: Replication Broken between Kafka 0.8.2.1 and 0.9 (trunk)

Hi Grant, Creating a patch for this issue actually wasn't a whole lot of work. I've uploaded one to the JIRA ticket. Thanks, Matt -Original Message- From: Matthew Bruce Sent: Thursday, November 5, 2015 3:52 PM To: 'dev@kafka.apache.org' Subject: RE: Replication Broken between Kafka 0

[jira] [Updated] (KAFKA-2756) Replication Broken between Kafka 0.8.2.1 and 0.9 - NetworkClient.java uses wrong protocol version

[ https://issues.apache.org/jira/browse/KAFKA-2756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthew Bruce updated KAFKA-2756: - Attachment: KAFKA-2756.patch > Replication Broken between Kafka 0.8.2.1 and 0.9 - NetworkClient.ja

[jira] [Updated] (KAFKA-2756) Replication Broken between Kafka 0.8.2.1 and 0.9 - NetworkClient.java uses wrong protocol version

[ https://issues.apache.org/jira/browse/KAFKA-2756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthew Bruce updated KAFKA-2756: - Affects Version/s: 0.9.0.0 Status: Patch Available (was: Open) diff --git a/client

[jira] [Updated] (KAFKA-2756) Replication Broken between Kafka 0.8.2.1 and 0.9 - NetworkClient.java uses wrong protocol version

[ https://issues.apache.org/jira/browse/KAFKA-2756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2756: - Fix Version/s: 0.9.0.0 > Replication Broken between Kafka 0.8.2.1 and 0.9 - NetworkClient.java use

[jira] [Assigned] (KAFKA-2756) Replication Broken between Kafka 0.8.2.1 and 0.9 - NetworkClient.java uses wrong protocol version

[ https://issues.apache.org/jira/browse/KAFKA-2756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-2756: Assignee: Guozhang Wang > Replication Broken between Kafka 0.8.2.1 and 0.9 - NetworkClient.

Build failed in Jenkins: kafka-trunk-jdk8 #103

See Changes: [wangguoz] KAFKA-2755: Suspicious reference forwarding cause NPE on [wangguoz] KAFKA-2735: BrokerEndPoint should support uppercase hostnames. -- Started by an SCM change [EnvInject]

[jira] [Commented] (KAFKA-2721) Avoid handling duplicate LeaderAndISR requests

[ https://issues.apache.org/jira/browse/KAFKA-2721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992520#comment-14992520 ] ASF GitHub Bot commented on KAFKA-2721: --- GitHub user lindong28 opened a pull request

[GitHub] kafka pull request: KAFKA-2721; Avoid handling duplicate LeaderAnd...

GitHub user lindong28 opened a pull request: https://github.com/apache/kafka/pull/436 KAFKA-2721; Avoid handling duplicate LeaderAndISR requests You can merge this pull request into a Git repository by running: $ git pull https://github.com/lindong28/kafka KAFKA-2721 Alternat

[jira] [Created] (KAFKA-2757) Consoliate BrokerEndPoint and EndPoint

Guozhang Wang created KAFKA-2757: Summary: Consoliate BrokerEndPoint and EndPoint Key: KAFKA-2757 URL: https://issues.apache.org/jira/browse/KAFKA-2757 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-2735) BrokerEndPoint should support uppercase hostnames

[ https://issues.apache.org/jira/browse/KAFKA-2735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992507#comment-14992507 ] ASF GitHub Bot commented on KAFKA-2735: --- Github user asfgit closed the pull request

[jira] [Resolved] (KAFKA-2735) BrokerEndPoint should support uppercase hostnames

[ https://issues.apache.org/jira/browse/KAFKA-2735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-2735. -- Resolution: Fixed Fix Version/s: 0.9.0.0 Issue resolved by pull request 415 [https://gith

[GitHub] kafka pull request: KAFKA-2735 BrokerEndPoint should support upper...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/415 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabl

[jira] [Commented] (KAFKA-2755) NPE thrown while handling DescribeGroup request for non-existent consumer group

[ https://issues.apache.org/jira/browse/KAFKA-2755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992480#comment-14992480 ] ASF GitHub Bot commented on KAFKA-2755: --- Github user asfgit closed the pull request

[GitHub] kafka pull request: KAFKA-2755: NPE thrown while handling Describe...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/435 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabl

[jira] [Resolved] (KAFKA-2755) NPE thrown while handling DescribeGroup request for non-existent consumer group

[ https://issues.apache.org/jira/browse/KAFKA-2755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-2755. -- Resolution: Fixed Fix Version/s: 0.9.0.0 Issue resolved by pull request 435 [https://gith

[jira] [Commented] (KAFKA-2350) Add KafkaConsumer pause capability

[ https://issues.apache.org/jira/browse/KAFKA-2350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992466#comment-14992466 ] Guozhang Wang commented on KAFKA-2350: -- I think this can be fixed by filtering out th

[jira] [Updated] (KAFKA-2750) Sender.java: handleProduceResponse does not check protocol version

[ https://issues.apache.org/jira/browse/KAFKA-2750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2750: - Affects Version/s: 0.10.0.0 > Sender.java: handleProduceResponse does not check protocol version >

[jira] [Commented] (KAFKA-2350) Add KafkaConsumer pause capability

[ https://issues.apache.org/jira/browse/KAFKA-2350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992452#comment-14992452 ] Jiangjie Qin commented on KAFKA-2350: - Ah, right. That would work. It still a bit weir

[jira] [Updated] (KAFKA-2756) Replication Broken between Kafka 0.8.2.1 and 0.9 - NetworkClient.java uses wrong protocol version

[ https://issues.apache.org/jira/browse/KAFKA-2756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthew Bruce updated KAFKA-2756: - Summary: Replication Broken between Kafka 0.8.2.1 and 0.9 - NetworkClient.java uses wrong protocol

RE: Replication Broken between Kafka 0.8.2.1 and 0.9 (trunk)

https://issues.apache.org/jira/browse/KAFKA-2756 -Original Message- From: Grant Henke [mailto:ghe...@cloudera.com] Sent: Thursday, November 5, 2015 3:37 PM To: dev@kafka.apache.org Subject: Re: Replication Broken between Kafka 0.8.2.1 and 0.9 (trunk) Hi Matt, Great. Just wanted to be su

[jira] [Created] (KAFKA-2756) Replication Broken between Kafka 0.8.2.1 and 0.9 - NetworkClient.java uses wrong protocl version

Matthew Bruce created KAFKA-2756: Summary: Replication Broken between Kafka 0.8.2.1 and 0.9 - NetworkClient.java uses wrong protocl version Key: KAFKA-2756 URL: https://issues.apache.org/jira/browse/KAFKA-2756

[jira] [Reopened] (KAFKA-2424) Consider introducing lint-like tool for Scala

[ https://issues.apache.org/jira/browse/KAFKA-2424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke reopened KAFKA-2424: > Consider introducing lint-like tool for Scala > - > >

[jira] [Commented] (KAFKA-2424) Consider introducing lint-like tool for Scala

[ https://issues.apache.org/jira/browse/KAFKA-2424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992436#comment-14992436 ] Grant Henke commented on KAFKA-2424: Cool, makes sense to me. I will re-open. Apologie

RE: Replication Broken between Kafka 0.8.2.1 and 0.9 (trunk)

I don’t mind opening a JIRA and testing a patch, I'm not sure how quickly I'd be able to contribute one on my own though. Thanks, Matt -Original Message- From: Grant Henke [mailto:ghe...@cloudera.com] Sent: Thursday, November 5, 2015 3:37 PM To: dev@kafka.apache.org Subject: Re: Replica

Re: Replication Broken between Kafka 0.8.2.1 and 0.9 (trunk)

Hi Matt, Great. Just wanted to be sure of the background. Are you interested in opening a jira and contributing a patch? If not would you be interested in testing a patch if I provided one? Thank you, Grant On Thu, Nov 5, 2015 at 2:31 PM, Matthew Bruce wrote: > Hi Grant, > > Yes, I have read a

[jira] [Commented] (KAFKA-2755) NPE thrown while handling DescribeGroup request for non-existent consumer group

[ https://issues.apache.org/jira/browse/KAFKA-2755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992411#comment-14992411 ] Ashish K Singh commented on KAFKA-2755: --- [~hachikuji], [~guozhang] mind taking a loo

RE: Replication Broken between Kafka 0.8.2.1 and 0.9 (trunk)

Hi Grant, Yes, I have read and followed the Upgrade documentation and I have set inter.broker.protocol.version=0.8.2.X and it does not resolve the issue - based on the part of the code it's occurring in, it uses the 'latest' version for any API Key, and not the one specified by 'inter.broker.p

[jira] [Commented] (KAFKA-2755) NPE thrown while handling DescribeGroup request for non-existent consumer group

[ https://issues.apache.org/jira/browse/KAFKA-2755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992408#comment-14992408 ] ASF GitHub Bot commented on KAFKA-2755: --- GitHub user SinghAsDev opened a pull reques

[GitHub] kafka pull request: KAFKA-2755: NPE thrown while handling Describe...

GitHub user SinghAsDev opened a pull request: https://github.com/apache/kafka/pull/435 KAFKA-2755: NPE thrown while handling DescribeGroup request for non-e… …xistent consumer group You can merge this pull request into a Git repository by running: $ git pull https://github.

[jira] [Commented] (KAFKA-2423) Introduce Scalastyle

[ https://issues.apache.org/jira/browse/KAFKA-2423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992404#comment-14992404 ] Grant Henke commented on KAFKA-2423: Thanks [~ijuma]. That makes sense. I will share w

Re: Replication Broken between Kafka 0.8.2.1 and 0.9 (trunk)

Hi Matthew, I have not read into the details of your issues but have done similar "rolling" upgrade testing myself. The reason replication breaks is due to some wire protocol changes. Just checking some preliminary things before digging in - Have you followed the upgrade steps outlined here?

[jira] [Commented] (KAFKA-2424) Consider introducing lint-like tool for Scala

[ https://issues.apache.org/jira/browse/KAFKA-2424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992398#comment-14992398 ] Ismael Juma commented on KAFKA-2424: I think there's some overlap, but they tend to ca

[jira] [Created] (KAFKA-2755) NPE thrown while handling DescribeGroup request for non-existent consumer group

Ashish K Singh created KAFKA-2755: - Summary: NPE thrown while handling DescribeGroup request for non-existent consumer group Key: KAFKA-2755 URL: https://issues.apache.org/jira/browse/KAFKA-2755 Proje

[jira] [Commented] (KAFKA-2424) Consider introducing lint-like tool for Scala

[ https://issues.apache.org/jira/browse/KAFKA-2424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992391#comment-14992391 ] Grant Henke commented on KAFKA-2424: It was on the basis that both are static code/sty

[jira] [Commented] (KAFKA-2730) partition-reassignment tool stops working due to error in registerMetric

[ https://issues.apache.org/jira/browse/KAFKA-2730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992392#comment-14992392 ] ASF GitHub Bot commented on KAFKA-2730: --- GitHub user guozhangwang opened a pull requ

[GitHub] kafka pull request: MINOR: follow-up KAFKA-2730 to use two tags fo...

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/434 MINOR: follow-up KAFKA-2730 to use two tags for broker id and fetcher id combination You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozha

[jira] [Commented] (KAFKA-2423) Introduce Scalastyle

[ https://issues.apache.org/jira/browse/KAFKA-2423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992390#comment-14992390 ] Ismael Juma commented on KAFKA-2423: My understanding is that this is something we wan

Replication Broken between Kafka 0.8.2.1 and 0.9 (trunk)

Hello Kafka Devs, I've been testing the upgrade procedure between Kafka 0.8.2.1 and Kafka 0.9.0.0 and have been having Replication issues between the two version, and I was wondering if anyone was aware of this issue (I just searched and this seems to be related to KAFKA-2750 raised yesterday )

[jira] [Commented] (KAFKA-2702) ConfigDef toHtmlTable() sorts in a way that is a bit confusing

[ https://issues.apache.org/jira/browse/KAFKA-2702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992387#comment-14992387 ] Grant Henke commented on KAFKA-2702: I have updated the pull request based on all disc

[jira] [Commented] (KAFKA-2424) Consider introducing lint-like tool for Scala

[ https://issues.apache.org/jira/browse/KAFKA-2424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992386#comment-14992386 ] Ismael Juma commented on KAFKA-2424: I'm not sure this is a duplicate. Can you please

[jira] [Resolved] (KAFKA-2424) Consider introducing lint-like tool for Scala

[ https://issues.apache.org/jira/browse/KAFKA-2424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke resolved KAFKA-2424. Resolution: Duplicate > Consider introducing lint-like tool for Scala >

[jira] [Commented] (KAFKA-2077) Add ability to specify a TopicPicker class for KafkaLog4jApender

[ https://issues.apache.org/jira/browse/KAFKA-2077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992363#comment-14992363 ] Ashish K Singh commented on KAFKA-2077: --- Hey guys, this seems to be interesting. Is

[jira] [Commented] (KAFKA-2350) Add KafkaConsumer pause capability

[ https://issues.apache.org/jira/browse/KAFKA-2350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992357#comment-14992357 ] Guozhang Wang commented on KAFKA-2350: -- Could this be resolved by calling {code} con

Jenkins build is back to normal : kafka-trunk-jdk7 #763

See

  1   2   >