[jira] [Commented] (KAFKA-9016) Warn when log dir stopped serving replicas

[ https://issues.apache.org/jira/browse/KAFKA-9016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16955425#comment-16955425 ] ASF GitHub Bot commented on KAFKA-9016: --- uttpal commented on pull request #7563: KA

[jira] [Commented] (KAFKA-8943) Move SecurityProviderCreator to a public package

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

[jira] [Updated] (KAFKA-8869) Map taskConfigs in KafkaConfigBackingStore grows monotonically despite of task removals

[ https://issues.apache.org/jira/browse/KAFKA-8869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-8869: - Fix Version/s: (was: 2.4.0) 2.50 Description: Investigation of https://issue

[jira] [Updated] (KAFKA-8597) Give access to the Dead Letter Queue APIs to Kafka Connect Developers

[ https://issues.apache.org/jira/browse/KAFKA-8597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-8597: - Fix Version/s: (was: 2.4.0) 2.5.0 > Give access to the Dead Letter Queue APIs to K

[jira] [Updated] (KAFKA-8531) Change default replication factor config

[ https://issues.apache.org/jira/browse/KAFKA-8531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-8531: - Fix Version/s: (was: 2.4.0) 2.5.0 Moving this to 2.5.0 since PR is not ready yet.

[jira] [Updated] (KAFKA-5722) Refactor ConfigCommand to use the AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-5722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-5722: - Fix Version/s: (was: 2.4.0) 2.5.0 > Refactor ConfigCommand to use the AdminClient

[jira] [Updated] (KAFKA-8847) Deprecate and remove usage of supporting classes in kafka.security.auth

[ https://issues.apache.org/jira/browse/KAFKA-8847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-8847: - Fix Version/s: (was: 2.4.0) 2.5.0 Moving this to 2.5.0 since PR is not ready yet.

[jira] [Updated] (KAFKA-7932) Streams needs to handle new Producer exceptions

[ https://issues.apache.org/jira/browse/KAFKA-7932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-7932: - Fix Version/s: (was: 2.4.0) 2.5.0 > Streams needs to handle new Producer exception

[jira] [Updated] (KAFKA-8959) Update Guava to 24 (or newer) or remove dependency

[ https://issues.apache.org/jira/browse/KAFKA-8959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-8959: - Fix Version/s: (was: 2.4.0) 2.5.0 > Update Guava to 24 (or newer) or remove depend

[jira] [Resolved] (KAFKA-8482) alterReplicaLogDirs should be better documented

[ https://issues.apache.org/jira/browse/KAFKA-8482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-8482. -- Fix Version/s: (was: 2.4.0) 2.5.0 Resolution: Fixed > alterReplicaLogDirs

[jira] [Commented] (KAFKA-8482) alterReplicaLogDirs should be better documented

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

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16955549#comment-16955549 ] Guozhang Wang commented on KAFKA-8803: -- At the time when you observed this issue, an

[jira] [Commented] (KAFKA-6108) Synchronizing on commits and StandbyTasks can be improved

[ https://issues.apache.org/jira/browse/KAFKA-6108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1690#comment-1690 ] Guozhang Wang commented on KAFKA-6108: -- I think Chris' PR did improve on the current

[jira] [Commented] (KAFKA-9063) KAfka producer throughput drops with number of topics even when producer is producing on one topic

[ https://issues.apache.org/jira/browse/KAFKA-9063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1699#comment-1699 ] Guozhang Wang commented on KAFKA-9063: -- [~bansalp] I think one potential cost which

[jira] [Commented] (KAFKA-8940) Flaky Test SmokeTestDriverIntegrationTest.shouldWorkWithRebalance

[ https://issues.apache.org/jira/browse/KAFKA-8940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16955581#comment-16955581 ] ASF GitHub Bot commented on KAFKA-8940: --- guozhangwang commented on pull request #75

[jira] [Commented] (KAFKA-8769) Consider computing stream time independently per key

[ https://issues.apache.org/jira/browse/KAFKA-8769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16955611#comment-16955611 ] Richard Yu commented on KAFKA-8769: --- Alright, so I made a KIP for the low traffic probl

[jira] [Issue Comment Deleted] (KAFKA-8769) Consider computing stream time independently per key

[ https://issues.apache.org/jira/browse/KAFKA-8769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Yu updated KAFKA-8769: -- Comment: was deleted (was: [~vvcephei] Just a thought. Would the low traffic problem be made significa

[jira] [Commented] (KAFKA-9069) Flaky Test AdminClientIntegrationTest.testCreatePartitions

[ https://issues.apache.org/jira/browse/KAFKA-9069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16955640#comment-16955640 ] Levani Kokhreidze commented on KAFKA-9069: -- [https://builds.apache.org/job/kafka

[jira] [Commented] (KAFKA-8522) Tombstones can survive forever

[ https://issues.apache.org/jira/browse/KAFKA-8522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16955646#comment-16955646 ] ASF GitHub Bot commented on KAFKA-8522: --- ConcurrencyPractitioner commented on pull

[jira] [Commented] (KAFKA-6989) Support Async Processing in Streams

[ https://issues.apache.org/jira/browse/KAFKA-6989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16955647#comment-16955647 ] ASF GitHub Bot commented on KAFKA-6989: --- ConcurrencyPractitioner commented on pull

[jira] [Assigned] (KAFKA-8940) Flaky Test SmokeTestDriverIntegrationTest.shouldWorkWithRebalance

[ https://issues.apache.org/jira/browse/KAFKA-8940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-8940: Assignee: Guozhang Wang (was: John Roesler) > Flaky Test SmokeTestDriverIntegrationTest.s

[jira] [Created] (KAFKA-9070) Kafka Connect - Get the wrong offset value comes from Kafka Connect after increase the number of offset storage topic partition to 3

kaikai.hou created KAFKA-9070: - Summary: Kafka Connect - Get the wrong offset value comes from Kafka Connect after increase the number of offset storage topic partition to 3 Key: KAFKA-9070 URL: https://issues.apache.

[jira] [Resolved] (KAFKA-8990) DOCS: node-kafka library no longer exists

[ https://issues.apache.org/jira/browse/KAFKA-8990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dongjin Lee resolved KAFKA-8990. Assignee: Dongjin Lee Resolution: Fixed Fixed: [https://cwiki.apache.org/confluence/display/K

[jira] [Commented] (KAFKA-8939) Flaky test ReassignPartitionsClusterTest#shouldTriggerReassignmentWithZnodePrecedenceOnControllerStartup

[ https://issues.apache.org/jira/browse/KAFKA-8939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16955734#comment-16955734 ] Alex Kokachev commented on KAFKA-8939: -- [https://builds.apache.org/job/kafka-pr-jdk1

[jira] [Comment Edited] (KAFKA-8939) Flaky test ReassignPartitionsClusterTest#shouldTriggerReassignmentWithZnodePrecedenceOnControllerStartup

[ https://issues.apache.org/jira/browse/KAFKA-8939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16955734#comment-16955734 ] Alex Kokachev edited comment on KAFKA-8939 at 10/21/19 3:58 AM: ---

[jira] [Commented] (KAFKA-8812) Rebalance Producers

[ https://issues.apache.org/jira/browse/KAFKA-8812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16955764#comment-16955764 ] Werner Daehn commented on KAFKA-8812: - @all  As feared, this is a request which does

[jira] [Commented] (KAFKA-9069) Flaky Test AdminClientIntegrationTest.testCreatePartitions

[ https://issues.apache.org/jira/browse/KAFKA-9069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16955797#comment-16955797 ] Levani Kokhreidze commented on KAFKA-9069: -- [https://builds.apache.org/job/kafka

[jira] [Commented] (KAFKA-4609) KTable/KTable join followed by groupBy and aggregate/count can result in duplicated results

[ https://issues.apache.org/jira/browse/KAFKA-4609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16955805#comment-16955805 ] Mark Tinsley commented on KAFKA-4609: - Also seeing this issue in version 2.2.1 Not a