[GitHub] kafka pull request #2573: MINOR: Cleanup org.apache.kafka.streams.kstream.in...

GitHub user original-brownbear opened a pull request: https://github.com/apache/kafka/pull/2573 MINOR: Cleanup org.apache.kafka.streams.kstream.internals.AbstractKTableKTableJoinValueGetterSupplier#storeNames (performance and clarity) Just a trivial fix improving the performance

[jira] [Commented] (KAFKA-2296) Not able to delete topic on latest kafka

[ https://issues.apache.org/jira/browse/KAFKA-2296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15873505#comment-15873505 ] Armin Braun commented on KAFKA-2296: I think we should mark this as duplicate accordingly then :) >

Re: [DISCUSS] KIP-124: Request rate quotas

I realized the main concern with this proposal is how user can interpret this CPU-percentage based quota. Since this quota is exposed to user, we need to explain to user how this quota is going to impact their application performance and convince them that the quota is now too low for their

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

Hey Jun, Could you please let me know if the solutions above could address your concern? I really want to move the discussion forward. Thanks, Dong On Tue, Feb 14, 2017 at 8:17 PM, Dong Lin wrote: > Hey Jun, > > Thanks for all your help and time to discuss this KIP. When

[jira] [Commented] (KAFKA-4776) Implement graceful handling for improperly formed compressed message sets

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

[GitHub] kafka pull request #2572: KAFKA-4776: Implement graceful handling for improp...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/2572 KAFKA-4776: Implement graceful handling for improperly formed compressed message sets You can merge this pull request into a Git repository by running: $ git pull

Re: [VOTE] 0.10.2.0 RC2

This vote passes with 12 +1 votes (4 bindings) and no 0 or -1 votes. +1 votes PMC Members: * Guozhang Wang * Jun Rao * Gwen Shapira * Neha Narkhede Committers: * Ismael Juma * Sriram Subramanian Community: * Tom Crayford * Magnus Edenhill * Mathieu Fenniak * Rajini Sivaram * Manikumar Reddy *

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

See

[jira] [Comment Edited] (KAFKA-4767) KafkaProducer is not joining its IO thread properly

[ https://issues.apache.org/jira/browse/KAFKA-4767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15873290#comment-15873290 ] Buğra Gedik edited comment on KAFKA-4767 at 2/18/17 6:49 PM: - Agreed. I did

[jira] [Comment Edited] (KAFKA-4767) KafkaProducer is not joining its IO thread properly

[ https://issues.apache.org/jira/browse/KAFKA-4767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15873290#comment-15873290 ] Buğra Gedik edited comment on KAFKA-4767 at 2/18/17 6:49 PM: - Agreed. I did

[jira] [Commented] (KAFKA-4767) KafkaProducer is not joining its IO thread properly

[ https://issues.apache.org/jira/browse/KAFKA-4767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15873290#comment-15873290 ] Buğra Gedik commented on KAFKA-4767: Agreed. I did not see ``this.sender.forceClose();`` earlier. >

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

See Changes: [ismael] MINOR: Replace for with foreach loop in common module -- [...truncated 19981 lines...] org.apache.kafka.streams.state.internals.SegmentIteratorTest >

[GitHub] kafka pull request #2571: HOTFIX: ClassCastException in Request logging

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

[jira] [Resolved] (KAFKA-4777) Kafka client Heartbeat thread use all the cpu.

[ https://issues.apache.org/jira/browse/KAFKA-4777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-4777. Resolution: Fixed Fix Version/s: 0.10.3.0 Issue resolved by pull request 2564

[jira] [Commented] (KAFKA-4777) Kafka client Heartbeat thread use all the cpu.

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

[GitHub] kafka pull request #2564: KAFKA-4777 fix client heartbeat non-stop retry iss...

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

[GitHub] kafka pull request #2571: HOTFIX: ClassCastException in Request logging

GitHub user original-brownbear opened a pull request: https://github.com/apache/kafka/pull/2571 HOTFIX: ClassCastException in Request logging Comming from [here](https://github.com/apache/kafka/pull/2570#issuecomment-280859637) Fixed ClassCastException resulting from

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

See Changes: [ismael] MINOR: Replace for with foreach loop in common module [ismael] MINOR: Increase consumer init timeout in throttling test [ismael] KAFKA-4774; Inner classes which don't need a reference to the outer c…

[jira] [Commented] (KAFKA-4196) Transient test failure: DeleteConsumerGroupTest.testConsumptionOnRecreatedTopicAfterTopicWideDeleteInZK

[ https://issues.apache.org/jira/browse/KAFKA-4196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15873239#comment-15873239 ] ASF GitHub Bot commented on KAFKA-4196: --- GitHub user original-brownbear opened a pull request:

[GitHub] kafka pull request #2570: KAFKA-4196: Improved Test Stability by Disabling Z...

GitHub user original-brownbear opened a pull request: https://github.com/apache/kafka/pull/2570 KAFKA-4196: Improved Test Stability by Disabling ZK Fsync and Fixed KafkaAPI Error Response This addresses https://issues.apache.org/jira/browse/KAFKA-4196 What I found was

[jira] [Commented] (KAFKA-4774) Inner classes which don't need a reference to the outer class should be static

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

[GitHub] kafka pull request #2558: KAFKA-4774. Inner classes which don't need a refer...

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

[GitHub] kafka pull request #2567: MINOR: Increase consumer init timeout in throttlin...

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

[GitHub] kafka pull request #2530: MINOR: Replacing for with foreach loop in common m...

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

[GitHub] kafka pull request #2569: MINOR: Add build_eclipse to .gitignore

GitHub user cshannon opened a pull request: https://github.com/apache/kafka/pull/2569 MINOR: Add build_eclipse to .gitignore build_eclipse is the configured output directory for eclipse when using the gradle eclipse plugin and should be ignored You can merge this pull request

[jira] [Commented] (KAFKA-4198) Transient test failure: ConsumerBounceTest.testConsumptionWithBrokerFailures

[ https://issues.apache.org/jira/browse/KAFKA-4198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15873134#comment-15873134 ] ASF GitHub Bot commented on KAFKA-4198: --- GitHub user original-brownbear opened a pull request:

[GitHub] kafka pull request #2568: Kafka 4198: Fix Race Condition in KafkaServer Shut...

GitHub user original-brownbear opened a pull request: https://github.com/apache/kafka/pull/2568 Kafka 4198: Fix Race Condition in KafkaServer Shutdown Fixes the initially reported issue in https://issues.apache.org/jira/browse/KAFKA-4198. The relevant part in fixing the