[jira] [Assigned] (KAFKA-4801) Transient test failure (part 2): ConsumerBounceTest.testConsumptionWithBrokerFailures

[ https://issues.apache.org/jira/browse/KAFKA-4801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Armin Braun reassigned KAFKA-4801: -- Assignee: Jason Gustafson (was: Armin Braun) > Transient test failure (part 2): > ConsumerBou

[jira] [Commented] (KAFKA-5097) KafkaConsumer.poll throws IllegalStateException

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

[GitHub] kafka pull request #2887: KAFKA-5097: Add testFetchAfterPartitionWithFetched...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2887 --- 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 enab

[jira] [Commented] (KAFKA-4986) Add producer per task support

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

[GitHub] kafka pull request #2854: KAFKA-4986: Adding producer per task (follow-up)

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2854 --- 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 enab

[GitHub] kafka pull request #2933: MINOR: Some cleanup in the transactional producer

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/2933 MINOR: Some cleanup in the transactional producer You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka minor-transactional-client-

[jira] [Commented] (KAFKA-5137) Controlled shutdown timeout message improvement

[ https://issues.apache.org/jira/browse/KAFKA-5137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988235#comment-15988235 ] Umesh Chaudhary commented on KAFKA-5137: Indeed [~cotedm]. Even the *socketTimeout

[jira] [Commented] (KAFKA-5137) Controlled shutdown timeout message improvement

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

[GitHub] kafka pull request #2932: KAFKA-5137 : Controlled shutdown timeout message i...

GitHub user umesh9794 opened a pull request: https://github.com/apache/kafka/pull/2932 KAFKA-5137 : Controlled shutdown timeout message improvement This PR improves the warning message by adding correct config details. You can merge this pull request into a Git repository by runnin

[jira] [Commented] (KAFKA-4593) Task migration during rebalance callback process could lead the obsoleted task's IllegalStateException

[ https://issues.apache.org/jira/browse/KAFKA-4593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988200#comment-15988200 ] Matthias J. Sax commented on KAFKA-4593: It is possible of A and B are on differen

[jira] [Comment Edited] (KAFKA-4593) Task migration during rebalance callback process could lead the obsoleted task's IllegalStateException

[ https://issues.apache.org/jira/browse/KAFKA-4593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988200#comment-15988200 ] Matthias J. Sax edited comment on KAFKA-4593 at 4/28/17 4:57 AM: ---

[jira] [Comment Edited] (KAFKA-5025) FetchRequestTest should use batches with more than one message

[ https://issues.apache.org/jira/browse/KAFKA-5025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15982953#comment-15982953 ] Umesh Chaudhary edited comment on KAFKA-5025 at 4/28/17 4:53 AM: ---

[jira] [Commented] (KAFKA-5132) Abort long running transactions

[ https://issues.apache.org/jira/browse/KAFKA-5132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988198#comment-15988198 ] Umesh Chaudhary commented on KAFKA-5132: Sure [~damianguy]. Can understand :) > A

[jira] [Comment Edited] (KAFKA-5070) org.apache.kafka.streams.errors.LockException: task [0_18] Failed to lock the state directory: /opt/rocksdb/pulse10/0_18

[ https://issues.apache.org/jira/browse/KAFKA-5070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988196#comment-15988196 ] Matthias J. Sax edited comment on KAFKA-5070 at 4/28/17 4:49 AM: ---

[jira] [Commented] (KAFKA-5070) org.apache.kafka.streams.errors.LockException: task [0_18] Failed to lock the state directory: /opt/rocksdb/pulse10/0_18

[ https://issues.apache.org/jira/browse/KAFKA-5070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988196#comment-15988196 ] Matthias J. Sax commented on KAFKA-5070: Not sure. I sounds like your locally cach

[jira] [Commented] (KAFKA-4144) Allow per stream/table timestamp extractor

[ https://issues.apache.org/jira/browse/KAFKA-4144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988191#comment-15988191 ] Matthias J. Sax commented on KAFKA-4144: [~miguno] I am not sure what you have in

[jira] [Commented] (KAFKA-4772) Exploit #peek to implement #print() and other methods

[ https://issues.apache.org/jira/browse/KAFKA-4772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988188#comment-15988188 ] Matthias J. Sax commented on KAFKA-4772: This JIRA is not about any public API cha

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

See Changes: [wangguoz] KAFKA-5005: IntegrationTestUtils to override consumer configs and reuse [wangguoz] KAFKA-5111: Code cleanup and improved log4j on StreamThread and Task [jason] KAFKA-4379; Follow-up to

[jira] [Commented] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988162#comment-15988162 ] Arpan commented on KAFKA-4477: -- Also not sure why I am unable to find this bug reference in

[jira] [Commented] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988159#comment-15988159 ] Arpan commented on KAFKA-4477: -- Hi Apurva, I shall send you the stack trace again but the beh

[jira] [Updated] (KAFKA-5140) Flaky ResetIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-5140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5140: --- Resolution: Fixed Status: Resolved (was: Patch Available) > Flaky ResetIntegrationTes

[jira] [Updated] (KAFKA-5063) Flaky ResetIntegrationTest.testReprocessingFromScratchAfterResetWithIntermediateUserTopic

[ https://issues.apache.org/jira/browse/KAFKA-5063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5063: --- Status: Patch Available (was: Open) https://github.com/apache/kafka/pull/2931 > Flaky > Res

[jira] [Assigned] (KAFKA-5063) Flaky ResetIntegrationTest.testReprocessingFromScratchAfterResetWithIntermediateUserTopic

[ https://issues.apache.org/jira/browse/KAFKA-5063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-5063: -- Assignee: Matthias J. Sax > Flaky > ResetIntegrationTest.testReprocessingFromScratchAf

[jira] [Commented] (KAFKA-5140) Flaky ResetIntegrationTest

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

[jira] [Updated] (KAFKA-5140) Flaky ResetIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-5140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5140: --- Status: Patch Available (was: Open) > Flaky ResetIntegrationTest > --

[GitHub] kafka pull request #2931: KAFKA-5140: Flaky ResetIntegrationTest

GitHub user mjsax opened a pull request: https://github.com/apache/kafka/pull/2931 KAFKA-5140: Flaky ResetIntegrationTest You can merge this pull request into a Git repository by running: $ git pull https://github.com/mjsax/kafka kafka-5140-flaky-reset-integration-test Alter

[jira] [Created] (KAFKA-5140) Flaky ResetIntegrationTest

Matthias J. Sax created KAFKA-5140: -- Summary: Flaky ResetIntegrationTest Key: KAFKA-5140 URL: https://issues.apache.org/jira/browse/KAFKA-5140 Project: Kafka Issue Type: Bug Compon

new contributor

Hello, My name is Bryan. I'd like to be added to the contributor list and, if it isn't claimed already, I'd like to work on KAFKA-5137. Thanks, Bryan

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

See

Jenkins build is back to normal : kafka-trunk-jdk8 #1458

See

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

See Changes: [ismael] KAFKA-5119; Ensure global metrics are empty before running [ismael] KAFKA-5101; Remove unused zkClient parameter in incrementControllerEpoch [wangguoz] KAFKA-5005: IntegrationTestUtils to

[jira] [Commented] (KAFKA-4801) Transient test failure (part 2): ConsumerBounceTest.testConsumptionWithBrokerFailures

[ https://issues.apache.org/jira/browse/KAFKA-4801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988049#comment-15988049 ] Jason Gustafson commented on KAFKA-4801: I submitted a patch to make the expectati

[jira] [Comment Edited] (KAFKA-4772) Exploit #peek to implement #print() and other methods

[ https://issues.apache.org/jira/browse/KAFKA-4772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988025#comment-15988025 ] james chien edited comment on KAFKA-4772 at 4/28/17 1:51 AM: -

[GitHub] kafka pull request #2930: MINOR: Make assignment expectation explicit in tes...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/2930 MINOR: Make assignment expectation explicit in testConsumptionWithBrokerFailures You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/ka

[jira] [Comment Edited] (KAFKA-4772) Exploit #peek to implement #print() and other methods

[ https://issues.apache.org/jira/browse/KAFKA-4772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988025#comment-15988025 ] james chien edited comment on KAFKA-4772 at 4/28/17 1:49 AM: -

[jira] [Comment Edited] (KAFKA-4772) Exploit #peek to implement #print() and other methods

[ https://issues.apache.org/jira/browse/KAFKA-4772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988025#comment-15988025 ] james chien edited comment on KAFKA-4772 at 4/28/17 1:47 AM: -

[jira] [Commented] (KAFKA-4830) Augment KStream.print() to allow users pass in extra parameters in the printed string

[ https://issues.apache.org/jira/browse/KAFKA-4830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988028#comment-15988028 ] james chien commented on KAFKA-4830: yes, I want to work on that ! > Augment KStream.

[jira] [Assigned] (KAFKA-4772) Exploit #peek to implement #print() and other methods

[ https://issues.apache.org/jira/browse/KAFKA-4772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] james chien reassigned KAFKA-4772: -- Assignee: james chien > Exploit #peek to implement #print() and other methods > ---

[jira] [Commented] (KAFKA-4772) Exploit #peek to implement #print() and other methods

[ https://issues.apache.org/jira/browse/KAFKA-4772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988025#comment-15988025 ] james chien commented on KAFKA-4772: I want to clarify the problem, as I know is want

[jira] [Commented] (KAFKA-4801) Transient test failure (part 2): ConsumerBounceTest.testConsumptionWithBrokerFailures

[ https://issues.apache.org/jira/browse/KAFKA-4801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988003#comment-15988003 ] Jason Gustafson commented on KAFKA-4801: [~original-brownbear] I couldn't reproduc

[GitHub] kafka pull request #2916: WIP: Avoid FileInputStream and FileOutputStream

Github user ijuma closed the pull request at: https://github.com/apache/kafka/pull/2916 --- 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-5103) Refactor AdminUtils to use zkUtils methods instad of zkUtils.zkClient

[ https://issues.apache.org/jira/browse/KAFKA-5103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-5103. Resolution: Fixed > Refactor AdminUtils to use zkUtils methods instad of zkUtils.zkClient >

[jira] [Updated] (KAFKA-5103) Refactor AdminUtils to use zkUtils methods instad of zkUtils.zkClient

[ https://issues.apache.org/jira/browse/KAFKA-5103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5103: --- Fix Version/s: 0.11.0.0 > Refactor AdminUtils to use zkUtils methods instad of zkUtils.zkClient >

[jira] [Commented] (KAFKA-5103) Refactor AdminUtils to use zkUtils methods instad of zkUtils.zkClient

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

[GitHub] kafka pull request #2888: KAFKA-5103 Refactor AdminUtils to use zkUtils meth...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2888 --- 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 enab

[GitHub] kafka pull request #2909: MINOR: adding global store must ensure unique name...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2909 --- 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 enab

[jira] [Commented] (KAFKA-4379) Remove caching of dirty and removed keys from StoreChangeLogger

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

[GitHub] kafka pull request #2908: KAFKA-4379 Followup: Avoid sending to changelog wh...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2908 --- 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 enab

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

See

[jira] [Updated] (KAFKA-4953) Global Store: cast exception when initialising with in-memory logged state store

[ https://issues.apache.org/jira/browse/KAFKA-4953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4953: - Labels: user-experience (was: ) > Global Store: cast exception when initialising with in-memory l

[jira] [Commented] (KAFKA-5111) Improve internal Task APIs

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

[GitHub] kafka pull request #2917: KAFKA-5111: code cleanup follow up

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2917 --- 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 enab

[jira] [Commented] (KAFKA-4801) Transient test failure (part 2): ConsumerBounceTest.testConsumptionWithBrokerFailures

[ https://issues.apache.org/jira/browse/KAFKA-4801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15987910#comment-15987910 ] Armin Braun commented on KAFKA-4801: Will try to reproduce again tomorrow ... > Trans

[jira] [Assigned] (KAFKA-4801) Transient test failure (part 2): ConsumerBounceTest.testConsumptionWithBrokerFailures

[ https://issues.apache.org/jira/browse/KAFKA-4801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Armin Braun reassigned KAFKA-4801: -- Assignee: Armin Braun > Transient test failure (part 2): > ConsumerBounceTest.testConsumptionW

[jira] [Commented] (KAFKA-5005) JoinIntegrationTest fails occasionally

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

[GitHub] kafka pull request #2920: KAFKA-5005: IntegrationTestUtils Consumers need to...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2920 --- 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 enab

[jira] [Updated] (KAFKA-5005) JoinIntegrationTest fails occasionally

[ https://issues.apache.org/jira/browse/KAFKA-5005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5005: - Resolution: Fixed Fix Version/s: 0.11.0.0 Status: Resolved (was: Patch Available

Re: [VOTE] KIP-112 - Handle disk failure for JBOD

Thanks to everyone who voted and provided feedback! This KIP is now adopted with 3 binding +1s (Jun, Joel, Becket) and 1 non-binding +1s (Radai) Dong On Thu, Apr 27, 2017 at 4:12 PM, Dong Lin wrote: > Thanks for the vote Jun! > > I think that statement is probably OK because it assumes that br

Re: [ANNOUCE] Apache Kafka 0.10.2.1 Released

Thanks for managing the release Gwen. And thanks to everyone who contributed. :) Ismael On Thu, Apr 27, 2017 at 7:52 PM, Gwen Shapira wrote: > The Apache Kafka community is pleased to announce the release for Apache > Kafka 0.10.2.1. This is a bug fix release that fixes 29 issues in 0.10.2.0. >

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

See Changes: [junrao] KAFKA-5028; convert kafka controller to a single-threaded event queue -- [...truncated 2.42 MB...] at hudson.util.SequentialExecutionQueue$Q

[jira] [Commented] (KAFKA-4763) Handle disk failure for JBOD (KIP-112)

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

[GitHub] kafka pull request #2929: KAFKA-4763; Handle disk failure for JBOD (KIP-112)

GitHub user lindong28 opened a pull request: https://github.com/apache/kafka/pull/2929 KAFKA-4763; Handle disk failure for JBOD (KIP-112) You can merge this pull request into a Git repository by running: $ git pull https://github.com/lindong28/kafka KAFKA-4763 Alternatively y

Re: [VOTE] KIP-112 - Handle disk failure for JBOD

Thanks for the vote Jun! I think that statement is probably OK because it assumes that broker has bad log directories. If all log directories are good, the replica should be created in one of the good log directories. It is clarified in the wiki that "Even if isNewReplica=false and replica is not

[jira] [Resolved] (KAFKA-5101) Remove KafkaController's incrementControllerEpoch method parameter

[ https://issues.apache.org/jira/browse/KAFKA-5101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-5101. Resolution: Fixed Fix Version/s: 0.11.0.0 Issue resolved by pull request 2886 [https://github

[jira] [Commented] (KAFKA-5101) Remove KafkaController's incrementControllerEpoch method parameter

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

[GitHub] kafka pull request #2886: KAFKA-5101 Remove KafkaController's incrementContr...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2886 --- 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 enab

Re: [VOTE] KIP-112 - Handle disk failure for JBOD

Hi, Dong, Thanks for the proposal. +1. Just one minor comment. in "3. Broker bootstraps with bad log directories", when a broker receives a LeaderAndIsrRequest with isNewReplica=False but not found on any good log directory, if all log directories are good, it seems that we should create the repl

[jira] [Resolved] (KAFKA-5119) Transient test failure SocketServerTest.testMetricCollectionAfterShutdown

[ https://issues.apache.org/jira/browse/KAFKA-5119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-5119. Resolution: Fixed Fix Version/s: 0.11.0.0 Issue resolved by pull request 2915 [https://github

[jira] [Commented] (KAFKA-5119) Transient test failure SocketServerTest.testMetricCollectionAfterShutdown

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

[GitHub] kafka pull request #2915: KAFKA-5119: Ensure global metrics are empty before...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2915 --- 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 enab

[jira] [Commented] (KAFKA-4801) Transient test failure (part 2): ConsumerBounceTest.testConsumptionWithBrokerFailures

[ https://issues.apache.org/jira/browse/KAFKA-4801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15987843#comment-15987843 ] Jason Gustafson commented on KAFKA-4801: Recent occurrence: https://jenkins.conflu

[jira] [Reopened] (KAFKA-4801) Transient test failure (part 2): ConsumerBounceTest.testConsumptionWithBrokerFailures

[ https://issues.apache.org/jira/browse/KAFKA-4801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-4801: -- > Transient test failure (part 2): > ConsumerBounceTest.testConsumptionWithBrokerFailures > ---

[jira] [Resolved] (KAFKA-5139) Transient failure ConsumerBounceTest.testConsumptionWithBrokerFailures

[ https://issues.apache.org/jira/browse/KAFKA-5139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-5139. Resolution: Duplicate Sorry for the noise. > Transient failure ConsumerBounceTest.testConsu

[jira] [Created] (KAFKA-5139) Transient failure ConsumerBounceTest.testConsumptionWithBrokerFailures

Jason Gustafson created KAFKA-5139: -- Summary: Transient failure ConsumerBounceTest.testConsumptionWithBrokerFailures Key: KAFKA-5139 URL: https://issues.apache.org/jira/browse/KAFKA-5139 Project: Kaf

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

See Changes: [jason] KAFKA-4818; Exactly once transactional clients -- [...truncated 835.78 KB...] kafka.coordinator.transaction.TransactionMarkerChannelManagerTest > sh

[jira] [Resolved] (KAFKA-5122) Kafka Streams unexpected off-heap memory growth

[ https://issues.apache.org/jira/browse/KAFKA-5122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5122. -- Resolution: Fixed > Kafka Streams unexpected off-heap memory growth > --

[jira] [Assigned] (KAFKA-5122) Kafka Streams unexpected off-heap memory growth

[ https://issues.apache.org/jira/browse/KAFKA-5122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-5122: Assignee: Guozhang Wang > Kafka Streams unexpected off-heap memory growth > ---

[jira] [Comment Edited] (KAFKA-5122) Kafka Streams unexpected off-heap memory growth

[ https://issues.apache.org/jira/browse/KAFKA-5122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15987806#comment-15987806 ] Guozhang Wang edited comment on KAFKA-5122 at 4/27/17 10:16 PM:

[jira] [Commented] (KAFKA-5122) Kafka Streams unexpected off-heap memory growth

[ https://issues.apache.org/jira/browse/KAFKA-5122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15987806#comment-15987806 ] Guozhang Wang commented on KAFKA-5122: -- [~jon_fuseelements] Thanks a lots for reporti

[jira] [Resolved] (KAFKA-5086) Update topic expiry time in Metadata every time the topic metadata is requested

[ https://issues.apache.org/jira/browse/KAFKA-5086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-5086. --- Resolution: Fixed Fix Version/s: 0.11.0.0 Issue resolved by pull request 2869 [https://

[jira] [Commented] (KAFKA-4818) Implement transactional clients

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

[jira] [Commented] (KAFKA-5086) Update topic expiry time in Metadata every time the topic metadata is requested

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

[GitHub] kafka pull request #2840: KAFKA-4818: Exactly once transactional clients

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2840 --- 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 enab

[GitHub] kafka pull request #2869: KAFKA-5086; Update topic expiry time in Metadata e...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2869 --- 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 enab

[jira] [Resolved] (KAFKA-4818) Implement transactional clients

[ https://issues.apache.org/jira/browse/KAFKA-4818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-4818. Resolution: Fixed Issue resolved by pull request 2840 [https://github.com/apache/kafka/pull/

Re: [DISCUSS] KIP-140: Add administrative RPCs for adding, deleting, and listing ACLs

Hi, Colin, Thanks for the KIP. Looks good overall. Just a few minor comments. 1. The controller is responsible for managing the state of topics. So, it makes sense for create/delete topic requests to be sent to the controller. The controller is not responsible for managing ACLs right now. So, it'

SIEMs Supported

Hi, What SIEMs are supported with Kafka messaging bus? RSA, NetWitness, QRADAR,etc? Would like to have a list. Thanks! -Kristen

[GitHub] kafka pull request #2923: MINOR: Fix a few transaction coordinator issues

Github user hachikuji closed the pull request at: https://github.com/apache/kafka/pull/2923 --- 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 e

[jira] [Commented] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15987661#comment-15987661 ] Joseph Aliase commented on KAFKA-4477: -- [~apurva] Im hitting this issue. Please refer

[GitHub] kafka-site pull request #55: Add Rajini to committers page

Github user asfgit closed the pull request at: https://github.com/apache/kafka-site/pull/55 --- 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 e

[jira] [Updated] (KAFKA-5138) MirrorMaker doesn't exit on send failure occasionally

[ https://issues.apache.org/jira/browse/KAFKA-5138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5138: --- Labels: newbie (was: ) > MirrorMaker doesn't exit on send failure occasionally >

[jira] [Updated] (KAFKA-5137) Controlled shutdown timeout message improvement

[ https://issues.apache.org/jira/browse/KAFKA-5137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5137: --- Labels: newbie (was: ) > Controlled shutdown timeout message improvement > --

[jira] [Created] (KAFKA-5138) MirrorMaker doesn't exit on send failure occasionally

Dustin Cote created KAFKA-5138: -- Summary: MirrorMaker doesn't exit on send failure occasionally Key: KAFKA-5138 URL: https://issues.apache.org/jira/browse/KAFKA-5138 Project: Kafka Issue Type: B

[jira] [Created] (KAFKA-5137) Controlled shutdown timeout message improvement

Dustin Cote created KAFKA-5137: -- Summary: Controlled shutdown timeout message improvement Key: KAFKA-5137 URL: https://issues.apache.org/jira/browse/KAFKA-5137 Project: Kafka Issue Type: Improve

[GitHub] kafka pull request #2928: HOTFIX [WIP]: Check on not owned partitions

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/2928 HOTFIX [WIP]: Check on not owned partitions You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka KHotfix-check-not-owned-par

[ANNOUCE] Apache Kafka 0.10.2.1 Released

The Apache Kafka community is pleased to announce the release for Apache Kafka 0.10.2.1. This is a bug fix release that fixes 29 issues in 0.10.2.0. All of the changes in this release can be found in the release notes: *https://archive.apache.org/dist/kafka/0.10.2.1/RELEASE_NOTES.html

Re: [DISCUSS] KIP-143: Controller Health Metrics

Thanks for the KIP - couple of comments: - Do you intend to actually use yammer metrics? or use kafka-metrics and split the timer into an explicit rate and time? I think long term we ought to move off yammer and use kafka-metrics only. Actually either is fine, but we should ideally use only one in

[jira] [Updated] (KAFKA-5107) remove preferred replica election state from ControllerContext

[ https://issues.apache.org/jira/browse/KAFKA-5107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Onur Karaman updated KAFKA-5107: Status: Patch Available (was: In Progress) > remove preferred replica election state from Controlle

[jira] [Work started] (KAFKA-5107) remove preferred replica election state from ControllerContext

[ https://issues.apache.org/jira/browse/KAFKA-5107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-5107 started by Onur Karaman. --- > remove preferred replica election state from ControllerContext >

[jira] [Commented] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15987228#comment-15987228 ] Apurva Mehta commented on KAFKA-4477: - Your stack trace alone doesn't indicate that yo

  1   2   >