[jira] [Commented] (KAFKA-2079) Support exhibitor

[ https://issues.apache.org/jira/browse/KAFKA-2079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14906141#comment-14906141 ] Helena Edelson commented on KAFKA-2079: --- [~joestein] Is there a ticket for the depen

[jira] [Commented] (KAFKA-2569) Kafka should write its metrics to a Kafka topic

[ https://issues.apache.org/jira/browse/KAFKA-2569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14906189#comment-14906189 ] UTKARSH BHATNAGAR commented on KAFKA-2569: -- [~otis] & [~wushujames] - This is the

[jira] [Comment Edited] (KAFKA-2569) Kafka should write its metrics to a Kafka topic

[ https://issues.apache.org/jira/browse/KAFKA-2569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14906189#comment-14906189 ] UTKARSH BHATNAGAR edited comment on KAFKA-2569 at 9/24/15 10:45 AM:

[GitHub] kafka pull request: KAFKA-2554: change 0.8.3 to 0.9.0 in ApiVersio...

GitHub user omkreddy opened a pull request: https://github.com/apache/kafka/pull/237 KAFKA-2554: change 0.8.3 to 0.9.0 in ApiVersion and other files Updated the version from 0.8.3 to 0.9.0. in ApiVersion. Also updated in gradle.propeties. You can merge this pull request into a Git

[jira] [Assigned] (KAFKA-2554) change 0.8.3 to 0.9.0 in ApiVersion

[ https://issues.apache.org/jira/browse/KAFKA-2554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy reassigned KAFKA-2554: -- Assignee: Manikumar Reddy > change 0.8.3 to 0.9.0 in ApiVersion > -

[jira] [Commented] (KAFKA-2554) change 0.8.3 to 0.9.0 in ApiVersion

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

Re: Producer becomes slow over time

What happens when the new producer that is getting 70 MB/s is started on a machine that is not part of the kafka cluster? Can you include your topic description/configuration, producer configuration, and broker configuration? On 9/24/15, 1:44 AM, "Prabhjot Bharaj" wrote: >Hi, > >I would like to

[jira] [Comment Edited] (KAFKA-2561) Optionally support OpenSSL for SSL/TLS

[ https://issues.apache.org/jira/browse/KAFKA-2561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14902896#comment-14902896 ] Ismael Juma edited comment on KAFKA-2561 at 9/24/15 2:37 PM: -

[jira] [Comment Edited] (KAFKA-2561) Optionally support OpenSSL for SSL/TLS

[ https://issues.apache.org/jira/browse/KAFKA-2561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14902896#comment-14902896 ] Ismael Juma edited comment on KAFKA-2561 at 9/24/15 2:42 PM: -

[jira] [Commented] (KAFKA-2573) Mirror maker system test hangs and eventually fails

[ https://issues.apache.org/jira/browse/KAFKA-2573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14906454#comment-14906454 ] Ismael Juma commented on KAFKA-2573: I think the test should fail fast indeed. The sys

[jira] [Comment Edited] (KAFKA-2573) Mirror maker system test hangs and eventually fails

[ https://issues.apache.org/jira/browse/KAFKA-2573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14906454#comment-14906454 ] Ismael Juma edited comment on KAFKA-2573 at 9/24/15 2:56 PM: -

Wrappers for Kafka APIs

Hello there, Hope you all having great time with kafka. I am just about to start with. I am looking for a API that act as a Connection manager in my app. Say, getting a producer instance and publishing. Getting all possible broker list and so on. I know we have snippet for all in the document. But

Re: [Discussion] KIP-34 Add Partitioner Change Listener to Partitioner Interface

HI Becket, Thanks for answering and providing feedback. I will withdraw KIP and put into rejected section. Thanks, Bhavesh On Mon, Sep 21, 2015 at 9:53 AM, Jiangjie Qin wrote: > Hey Bhavesh, > > I kind of think this metadata change capture logic should be implemented by > each user by themse

[GitHub] kafka pull request: KAFKA-2576; ConsumerPerformance hangs when SSL...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/236 --- 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-2576) ConsumerPerformance hangs when SSL enabled for Multi-Partition Topic

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

[jira] [Updated] (KAFKA-2576) ConsumerPerformance hangs when SSL enabled for Multi-Partition Topic

[ https://issues.apache.org/jira/browse/KAFKA-2576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2576: --- Resolution: Fixed Status: Resolved (was: Patch Available) > ConsumerPerformance hangs when SSL enable

[jira] [Reopened] (KAFKA-2548) kafka-merge-pr tool fails to update JIRA with fix version 0.9.0.0

[ https://issues.apache.org/jira/browse/KAFKA-2548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reopened KAFKA-2548: I was just testing the fix to the script. > kafka-merge-pr tool fails to update JIRA with fix version 0

[jira] [Resolved] (KAFKA-2548) kafka-merge-pr tool fails to update JIRA with fix version 0.9.0.0

[ https://issues.apache.org/jira/browse/KAFKA-2548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-2548. Resolution: Fixed Issue resolved by pull request 6 [https://github.com/ijuma/kafka/pull/6] > kafka-

Re: [VOTE] KIP-31 - Move to relative offsets in compressed message sets.

+1 On Wed, Sep 23, 2015 at 10:16 PM, Guozhang Wang wrote: > ＋1 > > On Wed, Sep 23, 2015 at 9:32 PM, Aditya Auradkar < > aaurad...@linkedin.com.invalid> wrote: > > > +1 > > > > On Wed, Sep 23, 2015 at 8:03 PM, Neha Narkhede > wrote: > > > > > +1 > > > > > > On Wed, Sep 23, 2015 at 6:21 PM, Todd

[jira] [Commented] (KAFKA-2561) Optionally support OpenSSL for SSL/TLS

[ https://issues.apache.org/jira/browse/KAFKA-2561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14906632#comment-14906632 ] Jiangjie Qin commented on KAFKA-2561: - [~ijuma] Just curious, have we found out why th

[GitHub] kafka pull request: KAFKA-2548; kafka-merge-pr tool fails to updat...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/238 KAFKA-2548; kafka-merge-pr tool fails to update JIRA with fix version 0.9.0.0 Simplified the logic to choose the default fix version. We just hardcode it for `trunk` and try to compute it based on

[jira] [Commented] (KAFKA-2548) kafka-merge-pr tool fails to update JIRA with fix version 0.9.0.0

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

[jira] [Updated] (KAFKA-2548) kafka-merge-pr tool fails to update JIRA with fix version 0.9.0.0

[ https://issues.apache.org/jira/browse/KAFKA-2548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2548: --- Labels: (was: newbie) Reviewer: Guozhang Wang Status: Patch Available (was: In Progress)

[jira] [Work started] (KAFKA-2548) kafka-merge-pr tool fails to update JIRA with fix version 0.9.0.0

[ https://issues.apache.org/jira/browse/KAFKA-2548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-2548 started by Ismael Juma. -- > kafka-merge-pr tool fails to update JIRA with fix version 0.9.0.0 > ---

Build failed in Jenkins: Kafka-trunk #632

See Changes: [junrao] KAFKA-2576; ConsumerPerformance hangs when SSL enabled for Multi-Partition Topic -- [...truncated 932 lines...] kafka.log.LogCleanerIntegrationTest > cleanerTest[0] PASSED kafk

[GitHub] kafka pull request: KAFKA-1387: Kafka getting stuck creating ephem...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/178 --- 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-1387) Kafka getting stuck creating ephemeral node it has already created when two zookeeper sessions are established in a very short period of time

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

[jira] [Updated] (KAFKA-1387) Kafka getting stuck creating ephemeral node it has already created when two zookeeper sessions are established in a very short period of time

[ https://issues.apache.org/jira/browse/KAFKA-1387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1387: --- Resolution: Fixed Status: Resolved (was: Patch Available) > Kafka getting stuck creating ephemeral no

[jira] [Commented] (KAFKA-2561) Optionally support OpenSSL for SSL/TLS

[ https://issues.apache.org/jira/browse/KAFKA-2561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14906669#comment-14906669 ] Ismael Juma commented on KAFKA-2561: [~becket_qin], there are two problems: * The JDK

[jira] [Updated] (KAFKA-2548) kafka-merge-pr tool fails to update JIRA with fix version 0.9.0.0

[ https://issues.apache.org/jira/browse/KAFKA-2548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2548: - Resolution: Fixed Status: Resolved (was: Patch Available) > kafka-merge-pr tool fails to

[GitHub] kafka pull request: KAFKA-2548; kafka-merge-pr tool fails to updat...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/238 --- 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-2548) kafka-merge-pr tool fails to update JIRA with fix version 0.9.0.0

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

[jira] [Commented] (KAFKA-2417) Ducktape tests for SSL/TLS

[ https://issues.apache.org/jira/browse/KAFKA-2417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14906722#comment-14906722 ] Ismael Juma commented on KAFKA-2417: Sorry for the delay [~rsivaram], are you still wi

[GitHub] kafka pull request: add unit test for OffsetResetStrategyTest

GitHub user lindong28 opened a pull request: https://github.com/apache/kafka/pull/239 add unit test for OffsetResetStrategyTest You can merge this pull request into a Git repository by running: $ git pull https://github.com/lindong28/kafka KAFKA-2390-followup Alternatively yo

Build failed in Jenkins: Kafka-trunk #633

See Changes: [junrao] KAFKA-1387: Kafka getting stuck creating ephemeral node it has already created when two zookeeper sessions are established in a very short period of time [wangguoz] KAFKA-2548; kafka-merge-pr tool fails to update JIR

[GitHub] kafka pull request: KAFKA-2554: change 0.8.3 to 0.9.0 in ApiVersio...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/237 --- 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-2554) change 0.8.3 to 0.9.0 in ApiVersion

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

[jira] [Resolved] (KAFKA-2554) change 0.8.3 to 0.9.0 in ApiVersion

[ https://issues.apache.org/jira/browse/KAFKA-2554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-2554. - Resolution: Fixed Thanks for contributing! > change 0.8.3 to 0.9.0 in ApiVersion > --

[jira] [Commented] (KAFKA-2561) Optionally support OpenSSL for SSL/TLS

[ https://issues.apache.org/jira/browse/KAFKA-2561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14906904#comment-14906904 ] Jiangjie Qin commented on KAFKA-2561: - [~ijuma] Thanks for the explanation. It looks J

[jira] [Commented] (KAFKA-2561) Optionally support OpenSSL for SSL/TLS

[ https://issues.apache.org/jira/browse/KAFKA-2561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14906918#comment-14906918 ] Ismael Juma commented on KAFKA-2561: The current plan is to go with the JDK implementa

Jenkins build is back to normal : Kafka-trunk #634

See

[jira] [Commented] (KAFKA-2573) Mirror maker system test hangs and eventually fails

[ https://issues.apache.org/jira/browse/KAFKA-2573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14907021#comment-14907021 ] Ashish K Singh commented on KAFKA-2573: --- OK, I have updated the PR to just make the

[jira] [Commented] (KAFKA-2390) OffsetOutOfRangeException should contain the Offset and Partition info.

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

[GitHub] kafka pull request: KAFKA-2390-followup; add unit test for OffsetO...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/239 --- 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] [Created] (KAFKA-2578) Client Metadata internal state should be synchronized

Jason Gustafson created KAFKA-2578: -- Summary: Client Metadata internal state should be synchronized Key: KAFKA-2578 URL: https://issues.apache.org/jira/browse/KAFKA-2578 Project: Kafka Issue

[jira] [Created] (KAFKA-2579) Unauthorized clients should not be able to join groups

Jason Gustafson created KAFKA-2579: -- Summary: Unauthorized clients should not be able to join groups Key: KAFKA-2579 URL: https://issues.apache.org/jira/browse/KAFKA-2579 Project: Kafka Iss

[jira] [Assigned] (KAFKA-2579) Unauthorized clients should not be able to join groups

[ https://issues.apache.org/jira/browse/KAFKA-2579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-2579: -- Assignee: Jason Gustafson > Unauthorized clients should not be able to join groups > -

[GitHub] kafka pull request: KAFKA-2579; prevent unauthorized clients from ...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/240 KAFKA-2579; prevent unauthorized clients from joining groups You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA-2579 Altern

[jira] [Commented] (KAFKA-2579) Unauthorized clients should not be able to join groups

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

Re: [VOTE] KIP-31 - Move to relative offsets in compressed message sets.

+1 on everything but the upgrade plan, which is a bit scary - will comment on the discuss thread. On Thu, Sep 24, 2015 at 9:51 AM, Mayuresh Gharat wrote: > +1 > > On Wed, Sep 23, 2015 at 10:16 PM, Guozhang Wang wrote: > >> ＋1 >> >> On Wed, Sep 23, 2015 at 9:32 PM, Aditya Auradkar < >> aaurad...@

Re: [DISCUSS] KIP-31 - Message format change proposal

The upgrade plan works, but the potentially long interim phase of skipping zero-copy for down-conversion could be problematic especially for large deployments with large consumer fan-out. It is not only going to be memory overhead but CPU as well - since you need to decompress, write absolute offse

[GitHub] kafka pull request: KAFKA-2373: Add Kafka-backed offset storage fo...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/202 --- 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-2373) Copycat distributed offset storage

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

[jira] [Updated] (KAFKA-2373) Copycat distributed offset storage

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

[jira] [Updated] (KAFKA-2571) KafkaLog4jAppender dies while specifying "acks" config

[ https://issues.apache.org/jira/browse/KAFKA-2571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2571: - Reviewer: Jun Rao > KafkaLog4jAppender dies while specifying "acks" config > -

[jira] [Commented] (KAFKA-2571) KafkaLog4jAppender dies while specifying "acks" config

[ https://issues.apache.org/jira/browse/KAFKA-2571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14907405#comment-14907405 ] Ewen Cheslack-Postava commented on KAFKA-2571: -- [~junrao] This one is a trivi

[GitHub] kafka pull request: KAFKA-2571: KafkaLog4jAppender dies while spec...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/231 --- 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-2571) KafkaLog4jAppender dies while specifying "acks" config

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

[jira] [Updated] (KAFKA-2571) KafkaLog4jAppender dies while specifying "acks" config

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

[jira] [Commented] (KAFKA-2373) Copycat distributed offset storage

[ https://issues.apache.org/jira/browse/KAFKA-2373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14907422#comment-14907422 ] Gwen Shapira commented on KAFKA-2373: - Thanks for the contribution [~ewencp] and for t

[GitHub] kafka pull request: KAFKA-2579; prevent unauthorized clients from ...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/240 --- 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-2579) Unauthorized clients should not be able to join groups

[ https://issues.apache.org/jira/browse/KAFKA-2579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-2579. - Resolution: Fixed Fix Version/s: 0.9.0.0 Issue resolved by pull request 240 [https://github

[jira] [Commented] (KAFKA-2579) Unauthorized clients should not be able to join groups

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

[GitHub] kafka pull request: KAFKA-2372: Add Kafka-backed storage of Copyca...

GitHub user ewencp opened a pull request: https://github.com/apache/kafka/pull/241 KAFKA-2372: Add Kafka-backed storage of Copycat configs. This also adds some other needed infrastructure for distributed Copycat, most importantly the DistributedHerder, and refactors some code fo

[jira] [Commented] (KAFKA-2372) Copycat distributed config storage

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

[jira] [Updated] (KAFKA-2372) Copycat distributed config storage

[ https://issues.apache.org/jira/browse/KAFKA-2372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2372: - Reviewer: Gwen Shapira Status: Patch Available (was: Open) > Copycat distri

[jira] [Commented] (KAFKA-2575) inconsistant offset count in replication-offset-checkpoint during lead election leads to huge exceptions

[ https://issues.apache.org/jira/browse/KAFKA-2575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14907444#comment-14907444 ] Warren Jin commented on KAFKA-2575: --- Just updated. We remove the replication-offset-che

Re: [DISCUSS] KIP-31 - Message format change proposal

Hi Joel, That is a valid concern. And that is actually why we had the message.format.version before. My original thinking was: 1. upgrade the broker to support both V1 and V2 for consumer/producer request. 2. configure broker to store V1 on the disk. (message.format.version = 1) 3. upgrade the co

Build failed in Jenkins: Kafka-trunk #637

See Changes: [cshapi] KAFKA-2571; KafkaLog4jAppender dies while specifying acks config [cshapi] KAFKA-2579; prevent unauthorized clients from joining groups -- [...truncated 3225 lines...] kafka.coor

[jira] [Commented] (KAFKA-106) Include rolledup segment size stats via jmx

[ https://issues.apache.org/jira/browse/KAFKA-106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14907589#comment-14907589 ] UTKARSH BHATNAGAR commented on KAFKA-106: - [~junrao] - I would like to submit a PR

[jira] [Commented] (KAFKA-2409) Have KafkaConsumer.committed() return null when there is no committed offset

[ https://issues.apache.org/jira/browse/KAFKA-2409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14907645#comment-14907645 ] Sreepathi Prasanna commented on KAFKA-2409: --- [~hachikuji] I haven't had time to

[jira] [Created] (KAFKA-2580) Kafka Broker keeps file handles open for all log files (even if its not written to/read from)

Vinoth Chandar created KAFKA-2580: - Summary: Kafka Broker keeps file handles open for all log files (even if its not written to/read from) Key: KAFKA-2580 URL: https://issues.apache.org/jira/browse/KAFKA-2580