[jira] [Commented] (KAFKA-8449) Restart task on reconfiguration under incremental cooperative rebalancing

2019-05-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16852729#comment-16852729 ] ASF GitHub Bot commented on KAFKA-8449: --- kkonstantine commented on pull request #68

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

2019-05-31 Thread Paolo Mazzoncini (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16852746#comment-16852746 ] Paolo Mazzoncini commented on KAFKA-5998: - Will this be included in 2.2.1? > /.c

[jira] [Commented] (KAFKA-7925) Constant 100% cpu usage by all kafka brokers

2019-05-31 Thread Abhi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16852787#comment-16852787 ] Abhi commented on KAFKA-7925: - Hi [~rsivaram] [~enothereska], Is there any update on this? W

[jira] [Created] (KAFKA-8454) Add Java AdminClient interface

2019-05-31 Thread Andy Coates (JIRA)
Andy Coates created KAFKA-8454: -- Summary: Add Java AdminClient interface Key: KAFKA-8454 URL: https://issues.apache.org/jira/browse/KAFKA-8454 Project: Kafka Issue Type: Bug Components

[jira] [Commented] (KAFKA-6958) Allow to define custom processor names with KStreams DSL

2019-05-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16853017#comment-16853017 ] ASF GitHub Bot commented on KAFKA-6958: --- bbejeck commented on pull request #6411: K

[jira] [Commented] (KAFKA-7995) Augment singleton protocol type to list for Kafka Consumer

2019-05-31 Thread Sagar Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16853054#comment-16853054 ] Sagar Rao commented on KAFKA-7995: -- Sure its sagarmeansoc...@gmail.com > Augment single

[jira] [Created] (KAFKA-8455) Add NothingSerde to Serdes

2019-05-31 Thread John Roesler (JIRA)
John Roesler created KAFKA-8455: --- Summary: Add NothingSerde to Serdes Key: KAFKA-8455 URL: https://issues.apache.org/jira/browse/KAFKA-8455 Project: Kafka Issue Type: Improvement Comp

[jira] [Commented] (KAFKA-8421) Allow consumer.poll() to return data in the middle of rebalance

2019-05-31 Thread Richard Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16853099#comment-16853099 ] Richard Yu commented on KAFKA-8421: --- A key issue here is when we stop sending the old r

[jira] [Commented] (KAFKA-7994) Improve Stream-Time for rebalances and restarts

2019-05-31 Thread Mateusz Owczarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16853118#comment-16853118 ] Mateusz Owczarek commented on KAFKA-7994: - Bruno's example above indicates it act

[jira] [Created] (KAFKA-8456) Flaky Test StoreUpgradeIntegrationTest#shouldMigratePersistentWindowStoreToTimestampedWindowStoreUsingPapi

2019-05-31 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8456: -- Summary: Flaky Test StoreUpgradeIntegrationTest#shouldMigratePersistentWindowStoreToTimestampedWindowStoreUsingPapi Key: KAFKA-8456 URL: https://issues.apache.org/jira/browse/KAFKA-8

[jira] [Created] (KAFKA-8457) Remove Log dependency from Replica

2019-05-31 Thread Vikas Singh (JIRA)
Vikas Singh created KAFKA-8457: -- Summary: Remove Log dependency from Replica Key: KAFKA-8457 URL: https://issues.apache.org/jira/browse/KAFKA-8457 Project: Kafka Issue Type: Bug Compon

[jira] [Commented] (KAFKA-8377) KTable#transformValue might lead to incorrect result in joins

2019-05-31 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16853186#comment-16853186 ] Guozhang Wang commented on KAFKA-8377: -- Yes, I'm suggesting to add another condition

[jira] [Commented] (KAFKA-7853) Refactor ConsumerCoordinator/AbstractCoordinator to reduce constructor parameter list

2019-05-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16853371#comment-16853371 ] ASF GitHub Bot commented on KAFKA-7853: --- abbccdda commented on pull request #6854:

[jira] [Updated] (KAFKA-8456) Flaky Test StoreUpgradeIntegrationTest#shouldMigratePersistentWindowStoreToTimestampedWindowStoreUsingPapi

2019-05-31 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8456: --- Component/s: unit tests > Flaky Test > StoreUpgradeIntegrationTest#shouldMigratePersistentW

[jira] [Updated] (KAFKA-8454) Add Java AdminClient interface

2019-05-31 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8454: --- Component/s: (was: streams) (was: core) > Add Java AdminClient inter

[jira] [Commented] (KAFKA-8377) KTable#transformValue might lead to incorrect result in joins

2019-05-31 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16853386#comment-16853386 ] Matthias J. Sax commented on KAFKA-8377: Cool. [~Yohan123] – let us know if you

[jira] [Commented] (KAFKA-7994) Improve Stream-Time for rebalances and restarts

2019-05-31 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16853388#comment-16853388 ] Matthias J. Sax commented on KAFKA-7994: Well. `suppress()` in not "affected" bec

[jira] [Updated] (KAFKA-8455) Add NothingSerde to Serdes

2019-05-31 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8455: --- Labels: beginner needs-kip newbie newbie++ (was: ) > Add NothingSerde to Serdes > --

[jira] [Updated] (KAFKA-8260) Flaky test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

2019-05-31 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8260: --- Affects Version/s: 2.2.0 > Flaky test > ConsumerBounceTest#testRollingBrokerRestartsWithSmal

[jira] [Commented] (KAFKA-8260) Flaky test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

2019-05-31 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16853401#comment-16853401 ] Matthias J. Sax commented on KAFKA-8260: Saw this test failing locally (2.2 branc

[jira] [Created] (KAFKA-8458) Flaky Test AdminClientIntegrationTest#testElectPreferredLeaders

2019-05-31 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-8458: -- Summary: Flaky Test AdminClientIntegrationTest#testElectPreferredLeaders Key: KAFKA-8458 URL: https://issues.apache.org/jira/browse/KAFKA-8458 Project: Kafka

[jira] [Created] (KAFKA-8459) Flakey test BaseQuotaTest#testThrottledRequest

2019-05-31 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8459: -- Summary: Flakey test BaseQuotaTest#testThrottledRequest Key: KAFKA-8459 URL: https://issues.apache.org/jira/browse/KAFKA-8459 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-8459) Flakey test BaseQuotaTest#testThrottledRequest

2019-05-31 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16853452#comment-16853452 ] Boyang Chen commented on KAFKA-8459: [~guozhang] [~rsivaram]What's the normal procedu

[jira] [Commented] (KAFKA-8410) Strengthen the types of Processors, at least in the DSL, maybe in the PAPI as well

2019-05-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16853453#comment-16853453 ] ASF GitHub Bot commented on KAFKA-8410: --- vvcephei commented on pull request #6833:

[jira] [Commented] (KAFKA-8410) Strengthen the types of Processors, at least in the DSL, maybe in the PAPI as well

2019-05-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16853454#comment-16853454 ] ASF GitHub Bot commented on KAFKA-8410: --- vvcephei commented on pull request #6856:

[jira] [Commented] (KAFKA-8459) Flakey test BaseQuotaTest#testThrottledRequest

2019-05-31 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16853480#comment-16853480 ] Guozhang Wang commented on KAFKA-8459: -- Yes, the usual fix is to use mock time inste

[jira] [Commented] (KAFKA-8286) KIP-460 Admin Leader Election RPC

2019-05-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16853496#comment-16853496 ] ASF GitHub Bot commented on KAFKA-8286: --- jsancio commented on pull request #6857: K

[jira] [Updated] (KAFKA-8286) KIP-460 Admin Leader Election RPC

2019-05-31 Thread Jose Armando Garcia Sancio (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jose Armando Garcia Sancio updated KAFKA-8286: -- Description: Tracking issue for implementing KIP-460. Tasks: # [Done]

[jira] [Created] (KAFKA-8460) Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition

2019-05-31 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8460: -- Summary: Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition Key: KAFKA-8460 URL: https://issues.apache.org/jira/browse/KAFKA-8460 Project: Kafka

[jira] [Updated] (KAFKA-8460) Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition

2019-05-31 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8460: --- Description: [https://builds.apache.org/job/kafka-pr-jdk11-scala2.12/5168/consoleFull]  *16:17:04*

[jira] [Created] (KAFKA-8461) Flakey test UncleanLeaderElectionTest#testUncleanLeaderElectionDisabledByTopicOverride

2019-05-31 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8461: -- Summary: Flakey test UncleanLeaderElectionTest#testUncleanLeaderElectionDisabledByTopicOverride Key: KAFKA-8461 URL: https://issues.apache.org/jira/browse/KAFKA-8461 Proj

[jira] [Updated] (KAFKA-8199) ClassCastException when trying to groupBy after suppress

2019-05-31 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-8199: - Priority: Blocker (was: Major) > ClassCastException when trying to groupBy after suppress >

[jira] [Resolved] (KAFKA-8199) ClassCastException when trying to groupBy after suppress

2019-05-31 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8199. -- Resolution: Fixed > ClassCastException when trying to groupBy after suppress >