[jira] [Commented] (KAFKA-10105) Regression in group coordinator dealing with flaky clients joining while leaving

[ https://issues.apache.org/jira/browse/KAFKA-10105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17143586#comment-17143586 ] Gokul Ramanan Subramanian commented on KAFKA-10105: --- Thanks [~hachikuj

[jira] [Commented] (KAFKA-9935) Kafka not releasing member from Consumer Group

[ https://issues.apache.org/jira/browse/KAFKA-9935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17143585#comment-17143585 ] Gokul Ramanan Subramanian commented on KAFKA-9935: -- [~skecskes] thanks f

[jira] [Commented] (KAFKA-10177) Replace/improve Percentiles metrics

[ https://issues.apache.org/jira/browse/KAFKA-10177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17143599#comment-17143599 ] Tom Bentley commented on KAFKA-10177: - Have you considered using HrdHistogram, or re

[GitHub] [kafka] michael-carter-instaclustr commented on a change in pull request #8844: KAFKA-9887 fix failed task or connector count on startup failure

michael-carter-instaclustr commented on a change in pull request #8844: URL: https://github.com/apache/kafka/pull/8844#discussion_r444715149 ## File path: connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerMetricsGroup.java ## @@ -0,0 +1,204 @@ +/* + * Licens

[GitHub] [kafka] michael-carter-instaclustr commented on a change in pull request #8844: KAFKA-9887 fix failed task or connector count on startup failure

michael-carter-instaclustr commented on a change in pull request #8844: URL: https://github.com/apache/kafka/pull/8844#discussion_r444715998 ## File path: connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerMetricsGroupTest.java ## @@ -0,0 +1,164 @@ +/* + * Li

[GitHub] [kafka] michael-carter-instaclustr commented on a change in pull request #8844: KAFKA-9887 fix failed task or connector count on startup failure

michael-carter-instaclustr commented on a change in pull request #8844: URL: https://github.com/apache/kafka/pull/8844#discussion_r444716522 ## File path: connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerMetricsGroupTest.java ## @@ -0,0 +1,164 @@ +/* + * Li

[GitHub] [kafka] michael-carter-instaclustr commented on a change in pull request #8844: KAFKA-9887 fix failed task or connector count on startup failure

michael-carter-instaclustr commented on a change in pull request #8844: URL: https://github.com/apache/kafka/pull/8844#discussion_r444716410 ## File path: connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerMetricsGroupTest.java ## @@ -0,0 +1,164 @@ +/* + * Li

[GitHub] [kafka] michael-carter-instaclustr commented on a change in pull request #8844: KAFKA-9887 fix failed task or connector count on startup failure

michael-carter-instaclustr commented on a change in pull request #8844: URL: https://github.com/apache/kafka/pull/8844#discussion_r444716683 ## File path: connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerMetricsGroupTest.java ## @@ -0,0 +1,164 @@ +/* + * Li

[GitHub] [kafka] leonardge opened a new pull request #8922: MINOR: Fixed some resource leaks.

leonardge opened a new pull request #8922: URL: https://github.com/apache/kafka/pull/8922 Ran [infer tool](https://fbinfer.com/). Fixed some resource leak. ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage a

[GitHub] [kafka] michael-carter-instaclustr commented on a change in pull request #8844: KAFKA-9887 fix failed task or connector count on startup failure

michael-carter-instaclustr commented on a change in pull request #8844: URL: https://github.com/apache/kafka/pull/8844#discussion_r444718803 ## File path: connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerTest.java ## @@ -336,14 +336,11 @@ public void testSt

[GitHub] [kafka] cadonna commented on a change in pull request #8902: KAFKA-10179: Pass correct changelog topic to state serdes

cadonna commented on a change in pull request #8902: URL: https://github.com/apache/kafka/pull/8902#discussion_r444724004 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractProcessorStateManager.java ## @@ -0,0 +1,33 @@ +/* + * Licensed to

[GitHub] [kafka] cadonna commented on a change in pull request #8902: KAFKA-10179: Pass correct changelog topic to state serdes

cadonna commented on a change in pull request #8902: URL: https://github.com/apache/kafka/pull/8902#discussion_r444729453 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java ## @@ -402,4 +402,9 @@ public TaskType taskTyp

[jira] [Commented] (KAFKA-9752) Consumer rebalance can be stuck after new member timeout with old JoinGroup version

[ https://issues.apache.org/jira/browse/KAFKA-9752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17143638#comment-17143638 ] Gokul Ramanan Subramanian commented on KAFKA-9752: -- Would be nice if we

[GitHub] [kafka] dnwe commented on pull request #8888: KAFKA-9150; DescribeGroup uses member assignment as metadata

dnwe commented on pull request #: URL: https://github.com/apache/kafka/pull/#issuecomment-648683403 Retest this please. This is an automated message from the Apache Git Service. To respond to the message, please log o

[GitHub] [kafka] cadonna commented on a change in pull request #8902: KAFKA-10179: Pass correct changelog topic to state serdes

cadonna commented on a change in pull request #8902: URL: https://github.com/apache/kafka/pull/8902#discussion_r444739053 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java ## @@ -118,16 +111,24 @@ public void logChange(f

[GitHub] [kafka] gunnarmorling commented on pull request #8895: KAFKA-8398 Avoiding NPE in ByteBufferUnmapper#unmap()

gunnarmorling commented on pull request #8895: URL: https://github.com/apache/kafka/pull/8895#issuecomment-648684744 Hey @rhauch, could you pick up and review this one perhaps? Thanks! This is an automated message from the Ap

[GitHub] [kafka] showuon commented on a change in pull request #8712: KAFKA-10006: Don't create internal topics when LeaderNotAvailableException

showuon commented on a change in pull request #8712: URL: https://github.com/apache/kafka/pull/8712#discussion_r444739758 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java ## @@ -98,9 +98,10 @@ public InternalTopicManage

[GitHub] [kafka] showuon commented on a change in pull request #8712: KAFKA-10006: Don't create internal topics when LeaderNotAvailableException

showuon commented on a change in pull request #8712: URL: https://github.com/apache/kafka/pull/8712#discussion_r444741037 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java ## @@ -242,11 +256,16 @@ public InternalTopicMan

[GitHub] [kafka] cadonna commented on a change in pull request #8902: KAFKA-10179: Pass correct changelog topic to state serdes

cadonna commented on a change in pull request #8902: URL: https://github.com/apache/kafka/pull/8902#discussion_r444744436 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java ## @@ -578,4 +577,10 @@ private StateStoreMetad

[GitHub] [kafka] cadonna commented on a change in pull request #8902: KAFKA-10179: Pass correct changelog topic to state serdes

cadonna commented on a change in pull request #8902: URL: https://github.com/apache/kafka/pull/8902#discussion_r444746235 ## File path: streams/src/test/java/org/apache/kafka/test/GlobalStateManagerStub.java ## @@ -88,4 +88,14 @@ public StateStore getGlobalStore(final String n

[GitHub] [kafka] omkreddy commented on pull request #8888: KAFKA-9150; DescribeGroup uses member assignment as metadata

omkreddy commented on pull request #: URL: https://github.com/apache/kafka/pull/#issuecomment-648752203 retest this please. This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [kafka] omkreddy commented on pull request #8888: KAFKA-9150; DescribeGroup uses member assignment as metadata

omkreddy commented on pull request #: URL: https://github.com/apache/kafka/pull/#issuecomment-648754452 @dnwe Thanks for the backport. LGTM. will merge after tests passed. This is an automated message from the Apache

[GitHub] [kafka] omkreddy commented on pull request #8885: KAFKA-8264: decrease the record size for flaky test

omkreddy commented on pull request #8885: URL: https://github.com/apache/kafka/pull/8885#issuecomment-648755215 retest this please This is an automated message from the Apache Git Service. To respond to the message, please lo

[GitHub] [kafka] omkreddy commented on a change in pull request #8885: KAFKA-8264: decrease the record size for flaky test

omkreddy commented on a change in pull request #8885: URL: https://github.com/apache/kafka/pull/8885#discussion_r444829978 ## File path: core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala ## @@ -800,7 +800,7 @@ class PlaintextConsumerTest extends BaseConsumer

[GitHub] [kafka] akatona84 commented on pull request #8859: MINOR: Upgrade jetty to 9.4.27.v20200227 and jersey to 2.31

akatona84 commented on pull request #8859: URL: https://github.com/apache/kafka/pull/8859#issuecomment-648768398 @ijuma , @kkonstantine could you cherrypick this to 2.5 too please? This is an automated message from the Apache

[jira] [Commented] (KAFKA-10182) Change number of partitions of __consumer_offsets

[ https://issues.apache.org/jira/browse/KAFKA-10182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17143807#comment-17143807 ] huxihx commented on KAFKA-10182: [~simpleBread] Did you have any chances to see if creat

[GitHub] [kafka] dongjinleekr commented on pull request #7898: KAFKA-9366: please consider upgrade log4j to log4j2 due to critical security problem CVE-2019-17571

dongjinleekr commented on pull request #7898: URL: https://github.com/apache/kafka/pull/7898#issuecomment-648795743 Here is the fix. I completed to implement all the features, migrating tests to follow log4j2 API, and rebasing onto the latest trunk, but there is a problem in logging messag

[jira] [Commented] (KAFKA-10105) Regression in group coordinator dealing with flaky clients joining while leaving

[ https://issues.apache.org/jira/browse/KAFKA-10105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17143837#comment-17143837 ] Ismael Juma commented on KAFKA-10105: - We should close this and KAFKA-9935 as duplic

[jira] [Updated] (KAFKA-10134) High CPU issue during rebalance in Kafka consumer after upgrading to 2.5

[ https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-10134: Fix Version/s: 2.5.1 2.6.0 > High CPU issue during rebalance in Kafka consumer

[jira] [Updated] (KAFKA-10134) High CPU issue during rebalance in Kafka consumer after upgrading to 2.5

[ https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-10134: Priority: Blocker (was: Major) > High CPU issue during rebalance in Kafka consumer after upgradin

[jira] [Commented] (KAFKA-10134) High CPU issue during rebalance in Kafka consumer after upgrading to 2.5

[ https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17143840#comment-17143840 ] Ismael Juma commented on KAFKA-10134: - Any additional thoughts [~guozhang]? [~seangu

[jira] [Comment Edited] (KAFKA-9752) Consumer rebalance can be stuck after new member timeout with old JoinGroup version

[ https://issues.apache.org/jira/browse/KAFKA-9752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17143841#comment-17143841 ] Ismael Juma edited comment on KAFKA-9752 at 6/24/20, 1:29 PM: -

[jira] [Commented] (KAFKA-9752) Consumer rebalance can be stuck after new member timeout with old JoinGroup version

[ https://issues.apache.org/jira/browse/KAFKA-9752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17143841#comment-17143841 ] Ismael Juma commented on KAFKA-9752: [~gokul2411s] That's to signal that they would b

[GitHub] [kafka] omkreddy merged pull request #8888: KAFKA-9150; DescribeGroup uses member assignment as metadata

omkreddy merged pull request #: URL: https://github.com/apache/kafka/pull/ This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to t

[jira] [Updated] (KAFKA-9150) DescribeGroup uses member assignment as metadata

[ https://issues.apache.org/jira/browse/KAFKA-9150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-9150: - Fix Version/s: 2.3.2 > DescribeGroup uses member assignment as metadata > ---

[GitHub] [kafka] showuon commented on pull request #8712: KAFKA-10006: Don't create internal topics when LeaderNotAvailableException

showuon commented on pull request #8712: URL: https://github.com/apache/kafka/pull/8712#issuecomment-648846927 Hi @ableegoldman , thanks for the good suggestion! I've updated in this commit: https://github.com/apache/kafka/pull/8712/commits/f378c34d10c57d796412ac946f867e5787f93af0. What I

[GitHub] [kafka] showuon edited a comment on pull request #8712: KAFKA-10006: Don't create internal topics when LeaderNotAvailableException

showuon edited a comment on pull request #8712: URL: https://github.com/apache/kafka/pull/8712#issuecomment-648846927 Hi @ableegoldman , thanks for the good suggestion! I've updated in this commit: https://github.com/apache/kafka/pull/8712/commits/f378c34d10c57d796412ac946f867e5787f93af0.

[jira] [Assigned] (KAFKA-10166) Excessive TaskCorruptedException seen in testing

[ https://issues.apache.org/jira/browse/KAFKA-10166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reassigned KAFKA-10166: - Assignee: Bruno Cadonna > Excessive TaskCorruptedException seen in testing > --

[GitHub] [kafka] showuon commented on a change in pull request #8885: KAFKA-8264: decrease the record size for flaky test

showuon commented on a change in pull request #8885: URL: https://github.com/apache/kafka/pull/8885#discussion_r444938895 ## File path: core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala ## @@ -800,7 +800,7 @@ class PlaintextConsumerTest extends BaseConsumerT

[GitHub] [kafka] showuon commented on a change in pull request #8885: KAFKA-8264: decrease the record size for flaky test

showuon commented on a change in pull request #8885: URL: https://github.com/apache/kafka/pull/8885#discussion_r444938895 ## File path: core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala ## @@ -800,7 +800,7 @@ class PlaintextConsumerTest extends BaseConsumerT

[GitHub] [kafka] showuon commented on a change in pull request #8885: KAFKA-8264: decrease the record size for flaky test

showuon commented on a change in pull request #8885: URL: https://github.com/apache/kafka/pull/8885#discussion_r444938895 ## File path: core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala ## @@ -800,7 +800,7 @@ class PlaintextConsumerTest extends BaseConsumerT

[GitHub] [kafka] rajinisivaram commented on pull request #8683: KAFKA-9893: Configurable TCP connection timeout and improve the initial metadata fetch

rajinisivaram commented on pull request #8683: URL: https://github.com/apache/kafka/pull/8683#issuecomment-648866027 retest this please This is an automated message from the Apache Git Service. To respond to the message, plea

[GitHub] [kafka] rajinisivaram commented on a change in pull request #8683: KAFKA-9893: Configurable TCP connection timeout and improve the initial metadata fetch

rajinisivaram commented on a change in pull request #8683: URL: https://github.com/apache/kafka/pull/8683#discussion_r444945541 ## File path: core/src/main/scala/kafka/admin/BrokerApiVersionsCommand.scala ## @@ -205,6 +205,8 @@ object BrokerApiVersionsCommand { private objec

[GitHub] [kafka] dajac commented on a change in pull request #8683: KAFKA-9893: Configurable TCP connection timeout and improve the initial metadata fetch

dajac commented on a change in pull request #8683: URL: https://github.com/apache/kafka/pull/8683#discussion_r444951226 ## File path: clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java ## @@ -357,6 +398,36 @@ private NodeConnectionState nodeState(Strin

[jira] [Commented] (KAFKA-10173) BufferUnderflowException during Kafka Streams Upgrade

[ https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17143917#comment-17143917 ] John Roesler commented on KAFKA-10173: -- Hi [~karsten.schnitter] , I have "good" ne

[jira] [Assigned] (KAFKA-9846) Race condition can lead to severe lag underestimate for active tasks

[ https://issues.apache.org/jira/browse/KAFKA-9846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vinoth Chandar reassigned KAFKA-9846: - Assignee: (was: Vinoth Chandar) > Race condition can lead to severe lag underestimat

[jira] [Assigned] (KAFKA-5636) Add Sliding-Window support for Aggregations

[ https://issues.apache.org/jira/browse/KAFKA-5636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leah Thomas reassigned KAFKA-5636: -- Assignee: Leah Thomas (was: Sophie Blee-Goldman) > Add Sliding-Window support for Aggregation

[jira] [Assigned] (KAFKA-4996) Fix findbugs multithreaded correctness warnings for streams

[ https://issues.apache.org/jira/browse/KAFKA-4996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leah Thomas reassigned KAFKA-4996: -- Assignee: Leah Thomas (was: Sophie Blee-Goldman) > Fix findbugs multithreaded correctness war

[jira] [Commented] (KAFKA-10173) BufferUnderflowException during Kafka Streams Upgrade

[ https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17143956#comment-17143956 ] Karsten Schnitter commented on KAFKA-10173: --- Hi [~vvcephei], That is great ne

[GitHub] [kafka] abbccdda commented on a change in pull request #8832: KAFKA-9377: Refactor StreamsPartitionAssignor Repartition Count Logic

abbccdda commented on a change in pull request #8832: URL: https://github.com/apache/kafka/pull/8832#discussion_r445001673 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java ## @@ -511,68 +576,86 @@ private boolean ch

[GitHub] [kafka] rajinisivaram commented on a change in pull request #8683: KAFKA-9893: Configurable TCP connection timeout and improve the initial metadata fetch

rajinisivaram commented on a change in pull request #8683: URL: https://github.com/apache/kafka/pull/8683#discussion_r445008715 ## File path: clients/src/test/java/org/apache/kafka/clients/ClusterConnectionStatesTest.java ## @@ -40,7 +40,12 @@ private final MockTime time

[jira] [Created] (KAFKA-10197) Elect preferred leader when completing a partition reassignment

Bob Barrett created KAFKA-10197: --- Summary: Elect preferred leader when completing a partition reassignment Key: KAFKA-10197 URL: https://issues.apache.org/jira/browse/KAFKA-10197 Project: Kafka

[jira] [Updated] (KAFKA-10197) Elect preferred leader when completing a partition reassignment

[ https://issues.apache.org/jira/browse/KAFKA-10197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bob Barrett updated KAFKA-10197: Description: Currently, when completing a partition reassignment, we elect a leader from the new

[GitHub] [kafka] d8tltanc commented on a change in pull request #8683: KAFKA-9893: Configurable TCP connection timeout and improve the initial metadata fetch

d8tltanc commented on a change in pull request #8683: URL: https://github.com/apache/kafka/pull/8683#discussion_r445042974 ## File path: clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java ## @@ -357,6 +398,36 @@ private NodeConnectionState nodeState(St

[GitHub] [kafka] d8tltanc commented on a change in pull request #8683: KAFKA-9893: Configurable TCP connection timeout and improve the initial metadata fetch

d8tltanc commented on a change in pull request #8683: URL: https://github.com/apache/kafka/pull/8683#discussion_r445048384 ## File path: clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java ## @@ -103,6 +103,14 @@ Utils.join(SecurityProtocol.names()

[GitHub] [kafka] d8tltanc commented on a change in pull request #8683: KAFKA-9893: Configurable TCP connection timeout and improve the initial metadata fetch

d8tltanc commented on a change in pull request #8683: URL: https://github.com/apache/kafka/pull/8683#discussion_r445048690 ## File path: clients/src/main/java/org/apache/kafka/common/utils/ExponentialBackoff.java ## @@ -0,0 +1,51 @@ +/* + * Licensed to the Apache Software Foun

[jira] [Commented] (KAFKA-7718) Allow customized header inheritance for stateful operators in DSL

[ https://issues.apache.org/jira/browse/KAFKA-7718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17144079#comment-17144079 ] Jorge Esteban Quilcate Otoya commented on KAFKA-7718: - [~guozhang], I

[GitHub] [kafka] d8tltanc commented on a change in pull request #8683: KAFKA-9893: Configurable TCP connection timeout and improve the initial metadata fetch

d8tltanc commented on a change in pull request #8683: URL: https://github.com/apache/kafka/pull/8683#discussion_r445054383 ## File path: clients/src/test/java/org/apache/kafka/clients/ClusterConnectionStatesTest.java ## @@ -40,7 +40,12 @@ private final MockTime time = new

[GitHub] [kafka] d8tltanc commented on a change in pull request #8683: KAFKA-9893: Configurable TCP connection timeout and improve the initial metadata fetch

d8tltanc commented on a change in pull request #8683: URL: https://github.com/apache/kafka/pull/8683#discussion_r445054740 ## File path: core/src/main/scala/kafka/admin/BrokerApiVersionsCommand.scala ## @@ -205,6 +205,8 @@ object BrokerApiVersionsCommand { private object Adm

[GitHub] [kafka] abbccdda commented on pull request #8549: KAFKA-9911: Add new PRODUCER_FENCED error code

abbccdda commented on pull request #8549: URL: https://github.com/apache/kafka/pull/8549#issuecomment-648958817 retest this This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [kafka] abbccdda commented on pull request #8712: KAFKA-10006: Don't create internal topics when LeaderNotAvailableException

abbccdda commented on pull request #8712: URL: https://github.com/apache/kafka/pull/8712#issuecomment-648962849 retest this This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [kafka] d8tltanc commented on a change in pull request #8683: KAFKA-9893: Configurable TCP connection timeout and improve the initial metadata fetch

d8tltanc commented on a change in pull request #8683: URL: https://github.com/apache/kafka/pull/8683#discussion_r445062773 ## File path: clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java ## @@ -103,6 +103,14 @@ Utils.join(SecurityProtocol.names()

[jira] [Commented] (KAFKA-9752) Consumer rebalance can be stuck after new member timeout with old JoinGroup version

[ https://issues.apache.org/jira/browse/KAFKA-9752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17144111#comment-17144111 ] Gokul Ramanan Subramanian commented on KAFKA-9752: -- [~ijuma] thanks for

[GitHub] [kafka] dajac commented on pull request #8683: KAFKA-9893: Configurable TCP connection timeout and improve the initial metadata fetch

dajac commented on pull request #8683: URL: https://github.com/apache/kafka/pull/8683#issuecomment-648969079 @d8tltanc It seems that many tests failed due to an IllegalStateException. It seems that isConnectionTimeout is called while the connection state is not Connecting. Do you have an i

[jira] [Commented] (KAFKA-7718) Allow customized header inheritance for stateful operators in DSL

[ https://issues.apache.org/jira/browse/KAFKA-7718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17144179#comment-17144179 ] Matthias J. Sax commented on KAFKA-7718: This is an interesting idea. The new met

[jira] [Commented] (KAFKA-10197) Elect preferred leader when completing a partition reassignment

[ https://issues.apache.org/jira/browse/KAFKA-10197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17144190#comment-17144190 ] Jun Rao commented on KAFKA-10197: - [~bob-barrett]: Thanks for filing the issue. In reas

[GitHub] [kafka] satishbellapu commented on pull request #8921: KAFKA-10160: Kafka MM2 consumer configuration

satishbellapu commented on pull request #8921: URL: https://github.com/apache/kafka/pull/8921#issuecomment-649007937 @mjsax can you label appropriately for merge. This is an automated message from the Apache Git Service. To r

[GitHub] [kafka] ableegoldman commented on a change in pull request #8902: KAFKA-10179: Pass correct changelog topic to state serdes

ableegoldman commented on a change in pull request #8902: URL: https://github.com/apache/kafka/pull/8902#discussion_r445107800 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractProcessorStateManager.java ## @@ -0,0 +1,33 @@ +/* + * Licens

[GitHub] [kafka] rhauch commented on pull request #7496: KAFKA-9018: Throw clearer exceptions on serialisation errors

rhauch commented on pull request #7496: URL: https://github.com/apache/kafka/pull/7496#issuecomment-649018335 ok to test This is an automated message from the Apache Git Service. To respond to the message, please log on to Gi

[jira] [Resolved] (KAFKA-10135) Extract Task#executeAndMaybeSwallow to be a general utility function into TaskManager

[ https://issues.apache.org/jira/browse/KAFKA-10135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-10135. - Resolution: Fixed > Extract Task#executeAndMaybeSwallow to be a general utility function into >

[jira] [Updated] (KAFKA-10135) Extract Task#executeAndMaybeSwallow to be a general utility function into TaskManager

[ https://issues.apache.org/jira/browse/KAFKA-10135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10135: Fix Version/s: 2.7.0 > Extract Task#executeAndMaybeSwallow to be a general utility function into

[jira] [Updated] (KAFKA-10126) Deprecate unused options in ConsumerPerformance

[ https://issues.apache.org/jira/browse/KAFKA-10126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10126: Fix Version/s: 2.7.0 > Deprecate unused options in ConsumerPerformance > -

[jira] [Updated] (KAFKA-10135) Extract Task#executeAndMaybeSwallow to be a general utility function into TaskManager

[ https://issues.apache.org/jira/browse/KAFKA-10135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10135: Affects Version/s: 2.6.0 2.5.0 > Extract Task#executeAndMaybeSwallow to be

[jira] [Updated] (KAFKA-10126) Deprecate unused options in ConsumerPerformance

[ https://issues.apache.org/jira/browse/KAFKA-10126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10126: Affects Version/s: 2.6.0 2.4.0 2.5.0 > Deprecate unu

[jira] [Updated] (KAFKA-9439) Add more public API tests for KafkaProducer

[ https://issues.apache.org/jira/browse/KAFKA-9439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9439: --- Priority: Minor (was: Major) > Add more public API tests for KafkaProducer > ---

[jira] [Updated] (KAFKA-10126) Deprecate unused options in ConsumerPerformance

[ https://issues.apache.org/jira/browse/KAFKA-10126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10126: Priority: Minor (was: Major) > Deprecate unused options in ConsumerPerformance >

[jira] [Updated] (KAFKA-9439) Add more public API tests for KafkaProducer

[ https://issues.apache.org/jira/browse/KAFKA-9439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9439: --- Fix Version/s: 2.7.0 > Add more public API tests for KafkaProducer >

[jira] [Updated] (KAFKA-10126) Deprecate unused options in ConsumerPerformance

[ https://issues.apache.org/jira/browse/KAFKA-10126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10126: Issue Type: Improvement (was: Bug) > Deprecate unused options in ConsumerPerformance > --

[jira] [Commented] (KAFKA-10140) Incremental config api excludes plugin config changes

[ https://issues.apache.org/jira/browse/KAFKA-10140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17144251#comment-17144251 ] Randall Hauch commented on KAFKA-10140: --- Is this a regression in 2.6? Can I retarg

[jira] [Updated] (KAFKA-9497) Brokers start up even if SASL provider is not loaded and throw NPE when clients connect

[ https://issues.apache.org/jira/browse/KAFKA-9497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-9497: - Fix Version/s: (was: 2.6.0) 2.7.0 Since this is not a blocker issue, as pa

[jira] [Updated] (KAFKA-8744) Add Support to Scala API for KIP-307 and KIP-479

[ https://issues.apache.org/jira/browse/KAFKA-8744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8744: - Fix Version/s: (was: 2.6.0) 2.7.0 Since this is not a blocker issue, as pa

[jira] [Updated] (KAFKA-9520) Deprecate ZooKeeper access for kafka-reassign-partitions.sh

[ https://issues.apache.org/jira/browse/KAFKA-9520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-9520: - Fix Version/s: (was: 2.6.0) 2.7.0 Since this is not a blocker issue, as pa

[jira] [Updated] (KAFKA-9397) Deprecate Direct Zookeeper access in Kafka Administrative Tools

[ https://issues.apache.org/jira/browse/KAFKA-9397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-9397: - Fix Version/s: (was: 2.6.0) 2.7.0 Since this is not a blocker issue, as pa

[jira] [Updated] (KAFKA-10158) Fix flaky kafka.admin.TopicCommandWithAdminClientTest#testDescribeUnderReplicatedPartitionsWhenReassignmentIsInProgress

[ https://issues.apache.org/jira/browse/KAFKA-10158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-10158: -- Fix Version/s: (was: 2.6.0) 2.7.0 Since this is not a blocker issue, as

[jira] [Updated] (KAFKA-10053) Update Document for new feature that Allow HTTP Response Headers to be Configured for Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-10053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-10053: -- Fix Version/s: (was: 2.6.0) 2.7.0 Since this is not a blocker issue, as

[jira] [Updated] (KAFKA-6078) Investigate failure of ReassignPartitionsClusterTest.shouldExpandCluster

[ https://issues.apache.org/jira/browse/KAFKA-6078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-6078: - Fix Version/s: (was: 2.6.0) 2.7.0 Since this is not a blocker issue, as pa

[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 ] Randall Hauch updated KAFKA-8597: - Fix Version/s: (was: 2.6.0) 2.7.0 Since this is not a blocker issue, as pa

[jira] [Updated] (KAFKA-10140) Incremental config api excludes plugin config changes

[ https://issues.apache.org/jira/browse/KAFKA-10140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-10140: -- Fix Version/s: (was: 2.6.0) 2.7.0 Since this is not a blocker issue, as

[jira] [Updated] (KAFKA-9096) Validate config inter-dependencies for KafkaConfig only after dynamic configs are loaded

[ https://issues.apache.org/jira/browse/KAFKA-9096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-9096: - Fix Version/s: (was: 2.6.0) 2.7.0 Since this is not a blocker issue, as pa

[jira] [Updated] (KAFKA-9145) AbstractCoordinator should respect retry backoff between rebalances

[ https://issues.apache.org/jira/browse/KAFKA-9145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-9145: - Fix Version/s: (was: 2.6.0) 2.7.0 Since this is not a blocker issue, as pa

[jira] [Updated] (KAFKA-9076) MirrorMaker 2.0 automated consumer offset sync

[ https://issues.apache.org/jira/browse/KAFKA-9076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-9076: - Fix Version/s: (was: 2.6.0) 2.7.0 Since this is not a blocker issue, as pa

[jira] [Updated] (KAFKA-9510) Quotas may resolve to incorrect value if user is empty

[ https://issues.apache.org/jira/browse/KAFKA-9510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-9510: - Fix Version/s: (was: 2.6.0) 2.7.0 Since this is not a blocker issue, as pa

[jira] [Updated] (KAFKA-9837) New RPC for notifying controller of failed replica

[ https://issues.apache.org/jira/browse/KAFKA-9837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-9837: - Fix Version/s: (was: 2.6.0) 2.7.0 Since this is not a blocker issue, as pa

[jira] [Updated] (KAFKA-9666) Transactional producer Epoch could not be reset

[ https://issues.apache.org/jira/browse/KAFKA-9666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-9666: - Fix Version/s: (was: 2.6.0) 2.7.0 Since this is not a blocker issue, as pa

[jira] [Updated] (KAFKA-9624) test_throttled_reassignment as EndToEndTest

[ https://issues.apache.org/jira/browse/KAFKA-9624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-9624: - Fix Version/s: (was: 2.6.0) 2.7.0 Since this is not a blocker issue, as pa

[jira] [Updated] (KAFKA-9333) Shim `core` module that targets default scala version (KIP-531)

[ https://issues.apache.org/jira/browse/KAFKA-9333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-9333: - Fix Version/s: (was: 2.6.0) 2.7.0 Since this is not a blocker issue, as pa

[jira] [Updated] (KAFKA-9846) Race condition can lead to severe lag underestimate for active tasks

[ https://issues.apache.org/jira/browse/KAFKA-9846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-9846: - Fix Version/s: (was: 2.6.0) 2.7.0 Since this is not a blocker issue, as pa

[jira] [Updated] (KAFKA-9621) AdminClient listOffsets operation does not respect retries and backoff

[ https://issues.apache.org/jira/browse/KAFKA-9621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-9621: - Fix Version/s: (was: 2.6.0) 2.7.0 Since this is not a blocker issue, as pa

[jira] [Updated] (KAFKA-7493) Rewrite test_broker_type_bounce_at_start

[ https://issues.apache.org/jira/browse/KAFKA-7493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-7493: - Fix Version/s: (was: 2.6.0) 2.7.0 Since this is not a blocker issue, as pa

[jira] [Updated] (KAFKA-9592) Safely abort Producer transactions during application shutdown

[ https://issues.apache.org/jira/browse/KAFKA-9592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-9592: - Fix Version/s: (was: 2.6.0) 2.7.0 Since this is not a blocker issue, as pa

  1   2   3   >