[GitHub] [kafka] guozhangwang commented on pull request #8924: KAFKA-10198: guard against recycling dirty state

guozhangwang commented on pull request #8924: URL: https://github.com/apache/kafka/pull/8924#issuecomment-649199285 Merged to trunk and cherry-picked to 2.6 This is an automated message from the Apache Git Service. To respond

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

michael-carter-instaclustr commented on pull request #8844: URL: https://github.com/apache/kafka/pull/8844#issuecomment-649196880 I've made changes to those test now @C0urante . I couple of things worth noting: Changing the mock of the WorkMetricsGroup to a real object needs a fair few mo

[jira] [Commented] (KAFKA-10198) Dirty tasks may be recycled instead of closed

[ https://issues.apache.org/jira/browse/KAFKA-10198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17144625#comment-17144625 ] Sophie Blee-Goldman commented on KAFKA-10198: - [~rhauch] the fix has been me

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

abbccdda commented on a change in pull request #8712: URL: https://github.com/apache/kafka/pull/8712#discussion_r445277549 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java ## @@ -179,31 +180,43 @@ public InternalTopicMa

[jira] [Updated] (KAFKA-10017) Flaky Test EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta

[ https://issues.apache.org/jira/browse/KAFKA-10017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-10017: Priority: Critical (was: Blocker) > Flaky Test EosBetaUpgradeIntegrationTest.shouldUpgrad

[jira] [Commented] (KAFKA-10017) Flaky Test EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta

[ https://issues.apache.org/jira/browse/KAFKA-10017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17144590#comment-17144590 ] Matthias J. Sax commented on KAFKA-10017: - The test is still subject to other bu

[GitHub] [kafka] guozhangwang merged pull request #8924: KAFKA-10198: guard against recycling dirty state

guozhangwang merged pull request #8924: URL: https://github.com/apache/kafka/pull/8924 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

[GitHub] [kafka] ableegoldman commented on a change in pull request #8926: KAFKA-10166: always invoke `postCommit` before closing a task

ableegoldman commented on a change in pull request #8926: URL: https://github.com/apache/kafka/pull/8926#discussion_r445262784 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java ## @@ -813,27 +821,6 @@ void shutdown(final boolean

[GitHub] [kafka] ableegoldman commented on a change in pull request #8926: KAFKA-10166: always invoke `postCommit` before closing a task

ableegoldman commented on a change in pull request #8926: URL: https://github.com/apache/kafka/pull/8926#discussion_r445262369 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java ## @@ -242,18 +242,16 @@ public void handleAssignmen

[jira] [Reopened] (KAFKA-8197) Flaky Test kafka.server.DynamicBrokerConfigTest > testPasswordConfigEncoderSecretChange

[ https://issues.apache.org/jira/browse/KAFKA-8197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reopened KAFKA-8197: Saw this fail again:  kafka.server.DynamicBrokerConfigTest > testPasswordConfigEncoderS

[GitHub] [kafka] ableegoldman commented on pull request #8924: KAFKA-10198: guard against recycling dirty state

ableegoldman commented on pull request #8924: URL: https://github.com/apache/kafka/pull/8924#issuecomment-649162622 Two unrelated test failures: `MirrorConnectorsIntegrationTest.testReplication` `DynamicBrokerConfigTest > testPasswordConfigEncoderSecretChange` ---

[GitHub] [kafka] ableegoldman opened a new pull request #8926: KAFKA-10166: always invoke `postCommit` before closing a task

ableegoldman opened a new pull request #8926: URL: https://github.com/apache/kafka/pull/8926 This should address at least some of the excessive TaskCorruptedExceptions we've been seeing lately. Basically, at the moment we only commit tasks if `commitNeeded` is true -- this seems true by de

[GitHub] [kafka] guozhangwang commented on pull request #8925: KAFKA-9974: Make produce-sync flush

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

[GitHub] [kafka] guozhangwang opened a new pull request #8925: KAFKA-9974: Make produce-sync flush

guozhangwang opened a new pull request #8925: URL: https://github.com/apache/kafka/pull/8925 I cannot actually re-produce the failure locally, but by looking at the code I think there's an issue in `produceKeyValuesSynchronously`: when Eos is not enabled, we then need to call `flush` to ma

[GitHub] [kafka] guozhangwang removed a comment on pull request #8925: KAFKA-9974: Make produce-sync flush

guozhangwang removed a comment on pull request #8925: URL: https://github.com/apache/kafka/pull/8925#issuecomment-649157091 test this This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [kafka] guozhangwang commented on pull request #8925: KAFKA-9974: Make produce-sync flush

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

[GitHub] [kafka] guozhangwang commented on pull request #8925: KAFKA-9974: Make produce-sync flush

guozhangwang commented on pull request #8925: URL: https://github.com/apache/kafka/pull/8925#issuecomment-649157091 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub a

[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=17144573#comment-17144573 ] Boyang Chen commented on KAFKA-10173: - cc [~rhauch] > BufferUnderflowException duri

[jira] [Commented] (KAFKA-10017) Flaky Test EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta

[ https://issues.apache.org/jira/browse/KAFKA-10017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17144567#comment-17144567 ] Sophie Blee-Goldman commented on KAFKA-10017: - cc [~mjsax] > Flaky Test Eos

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

[ https://issues.apache.org/jira/browse/KAFKA-10166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17144562#comment-17144562 ] Sophie Blee-Goldman commented on KAFKA-10166: - I think this should be a bloc

[GitHub] [kafka] guozhangwang commented on pull request #8924: KAFKA-10198: guard against recycling dirty state

guozhangwang commented on pull request #8924: URL: https://github.com/apache/kafka/pull/8924#issuecomment-649137974 LGTM. This is an automated message from the Apache Git Service. To respond to the message, please log on to G

[GitHub] [kafka] junrao commented on a change in pull request #8479: KAFKA-9769: Finish operations for leaderEpoch-updated partitions up to point ZK Exception

junrao commented on a change in pull request #8479: URL: https://github.com/apache/kafka/pull/8479#discussion_r445234702 ## File path: core/src/main/scala/kafka/server/ReplicaManager.scala ## @@ -1556,6 +1557,11 @@ class ReplicaManager(val config: KafkaConfig, erro

[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=17144485#comment-17144485 ] John Roesler commented on KAFKA-10173: -- Ok, I'm horrified and embarrassed to report

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

[ https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10173: - Fix Version/s: 2.4.2 2.6.0 > BufferUnderflowException during Kafka Streams Up

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

[ https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10173: - Priority: Blocker (was: Major) > BufferUnderflowException during Kafka Streams Upgrade > --

[jira] [Updated] (KAFKA-9313) Set default for client.dns.lookup to use_all_dns_ips

[ https://issues.apache.org/jira/browse/KAFKA-9313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-9313: - Fix Version/s: (was: 2.7.0) 2.6.0 > Set default for client.dns.lookup to u

[jira] [Updated] (KAFKA-9313) Set default for client.dns.lookup to use_all_dns_ips

[ https://issues.apache.org/jira/browse/KAFKA-9313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-9313: - Labels: need-kip (was: ) > Set default for client.dns.lookup to use_all_dns_ips > --

[jira] [Commented] (KAFKA-9313) Set default for client.dns.lookup to use_all_dns_ips

[ https://issues.apache.org/jira/browse/KAFKA-9313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17144481#comment-17144481 ] Randall Hauch commented on KAFKA-9313: -- Actually, this looks like it was merged and

[GitHub] [kafka] mjsax commented on pull request #8924: KAFKA-10198: guard against recycling dirty state

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

[jira] [Commented] (KAFKA-10198) Dirty tasks may be recycled instead of closed

[ https://issues.apache.org/jira/browse/KAFKA-10198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17144472#comment-17144472 ] Randall Hauch commented on KAFKA-10198: --- Thanks, [~ableegoldman]. I agree this sho

[jira] [Commented] (KAFKA-9381) kafka-streams-scala: Javadocs + Scaladocs not published on maven central

[ https://issues.apache.org/jira/browse/KAFKA-9381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17144469#comment-17144469 ] Randall Hauch commented on KAFKA-9381: -- [~mumrah] can you share the changes you made

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

d8tltanc commented on pull request #8683: URL: https://github.com/apache/kafka/pull/8683#issuecomment-649113870 @rajinisivaram @dajac The test failures are caused by the connection state transition from `CONNECTING` to `CHECKING_API_VERSIONS`, and then to `CONNECTED`, instead of to `CONNEC

[GitHub] [kafka] ableegoldman commented on a change in pull request #8924: KAFKA-10198: guard against recycling dirty state

ableegoldman commented on a change in pull request #8924: URL: https://github.com/apache/kafka/pull/8924#discussion_r445212765 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java ## @@ -515,17 +517,20 @@ private void writeCheckpoint

[GitHub] [kafka] ableegoldman opened a new pull request #8924: KAFKA-10198: guard against recycling dirty state

ableegoldman opened a new pull request #8924: URL: https://github.com/apache/kafka/pull/8924 We just needed to add the check in `StreamTask#closeClean` to `closeAndRecycleState` as well. Also renamed `closeAndRecycleState` to `closeCleanAndRecycleState` to drive this point home: it

[jira] [Created] (KAFKA-10198) Dirty tasks may be recycled instead of closed

Sophie Blee-Goldman created KAFKA-10198: --- Summary: Dirty tasks may be recycled instead of closed Key: KAFKA-10198 URL: https://issues.apache.org/jira/browse/KAFKA-10198 Project: Kafka I

[GitHub] [kafka] ning2008wisc commented on pull request #7577: KAFKA-9076: support consumer offset sync across clusters in MM 2.0

ning2008wisc commented on pull request #7577: URL: https://github.com/apache/kafka/pull/7577#issuecomment-649092864 bump for attention @mimaison ^ given that https://issues.apache.org/jira/browse/KAFKA-9076 is slipped to the next release (2.7.0) and some people may be already testing/using

[GitHub] [kafka] vvcephei commented on pull request #8881: KIP-557: Add emit on change support to Kafka Streams

vvcephei commented on pull request #8881: URL: https://github.com/apache/kafka/pull/8881#issuecomment-649089312 Hey @ConcurrencyPractitioner , I'm sorry for the delay. I started to look at it, but got caught up in stabilizing the 2.6.0 and 2.5.1 releases. I'll get you a review ASAP.

[GitHub] [kafka] andrewchoi5 commented on pull request #8479: KAFKA-9769: Finish operations for leaderEpoch-updated partitions up to point ZK Exception

andrewchoi5 commented on pull request #8479: URL: https://github.com/apache/kafka/pull/8479#issuecomment-649082464 Hello @junrao @hachikuji -- I have made some updates to address the comments. Thanks! This is an automated m

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

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

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17144398#comment-17144398 ] Sophie Blee-Goldman commented on KAFKA-9846: This is definitely a limitation

[jira] [Commented] (KAFKA-10068) Verify HighAvailabilityTaskAssignor performance with large clusters and topologies

[ https://issues.apache.org/jira/browse/KAFKA-10068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17144394#comment-17144394 ] Sophie Blee-Goldman commented on KAFKA-10068: - Moved the fix version back to

[jira] [Updated] (KAFKA-10068) Verify HighAvailabilityTaskAssignor performance with large clusters and topologies

[ https://issues.apache.org/jira/browse/KAFKA-10068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-10068: Fix Version/s: (was: 2.6.0) 2.7.0 > Verify HighAvailability

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

[ https://issues.apache.org/jira/browse/KAFKA-9076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17144388#comment-17144388 ] Ning Zhang commented on KAFKA-9076: --- [~rhauch] It is true that this jira is not a block

[jira] [Commented] (KAFKA-4740) Using new consumer API with a Deserializer that throws SerializationException can lead to infinite loop

[ https://issues.apache.org/jira/browse/KAFKA-4740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17144384#comment-17144384 ] Patrick Taylor commented on KAFKA-4740: --- I agree with [Andrea's comment on 12/Dec/1

[jira] [Commented] (KAFKA-9861) Process Simplification - Community Validation of Kafka Release Candidates

[ https://issues.apache.org/jira/browse/KAFKA-9861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17144383#comment-17144383 ] Randall Hauch commented on KAFKA-9861: -- Since this is not a blocker issue, as releas

[jira] [Updated] (KAFKA-9861) Process Simplification - Community Validation of Kafka Release Candidates

[ https://issues.apache.org/jira/browse/KAFKA-9861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-9861: - Fix Version/s: (was: 2.6.0) 2.6.1 > Process Simplification - Community Val

[jira] [Updated] (KAFKA-9861) Process Simplification - Community Validation of Kafka Release Candidates

[ https://issues.apache.org/jira/browse/KAFKA-9861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-9861: - Fix Version/s: 2.7.0 > Process Simplification - Community Validation of Kafka Release Candidates

[jira] [Updated] (KAFKA-9313) Set default for client.dns.lookup to use_all_dns_ips

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

[jira] [Updated] (KAFKA-9587) Producer configs are omitted in the documentation

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

[jira] [Updated] (KAFKA-10038) ConsumerPerformance.scala supports the setting of client.id

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

[jira] [Updated] (KAFKA-8930) MM2 documentation

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

[jira] [Updated] (KAFKA-8929) MM2 system tests

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

[jira] [Updated] (KAFKA-9018) Kafka Connect - throw clearer exceptions on serialisation errors

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

[jira] [Commented] (KAFKA-10068) Verify HighAvailabilityTaskAssignor performance with large clusters and topologies

[ https://issues.apache.org/jira/browse/KAFKA-10068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17144375#comment-17144375 ] Randall Hauch commented on KAFKA-10068: --- [~ableegoldman], actually, I'm still tryi

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

[ https://issues.apache.org/jira/browse/KAFKA-8264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8264: - Fix Version/s: (was: 2.6.0) 2.6.1 2.7.0 > Flaky Test Pl

[jira] [Commented] (KAFKA-8264) Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition

[ https://issues.apache.org/jira/browse/KAFKA-8264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17144374#comment-17144374 ] Randall Hauch commented on KAFKA-8264: -- Since this is not a blocker issue, as part o

[jira] [Commented] (KAFKA-9943) Enable TLSv.1.3 in system tests "run all" execution.

[ https://issues.apache.org/jira/browse/KAFKA-9943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17144372#comment-17144372 ] Randall Hauch commented on KAFKA-9943: -- Since this is not a blocker issue, as part o

[jira] [Commented] (KAFKA-5453) Controller may miss requests sent to the broker when zk session timeout happens.

[ https://issues.apache.org/jira/browse/KAFKA-5453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17144373#comment-17144373 ] Randall Hauch commented on KAFKA-5453: -- Moving this to 2.7.0 as there is no progress

[jira] [Updated] (KAFKA-5453) Controller may miss requests sent to the broker when zk session timeout happens.

[ https://issues.apache.org/jira/browse/KAFKA-5453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-5453: - Fix Version/s: (was: 2.6.0) 2.7.0 > Controller may miss requests sent to t

[jira] [Updated] (KAFKA-9943) Enable TLSv.1.3 in system tests "run all" execution.

[ https://issues.apache.org/jira/browse/KAFKA-9943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-9943: - Fix Version/s: (was: 2.6.0) 2.7.0 > Enable TLSv.1.3 in system tests "run a

[jira] [Commented] (KAFKA-10185) Streams should log summarized restoration information at info level

[ https://issues.apache.org/jira/browse/KAFKA-10185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17144371#comment-17144371 ] Randall Hauch commented on KAFKA-10185: --- Since this is not a blocker issue, as par

[jira] [Updated] (KAFKA-9458) Kafka crashed in windows environment

[ https://issues.apache.org/jira/browse/KAFKA-9458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-9458: - Fix Version/s: (was: 2.6.0) 2.7.0 > Kafka crashed in windows environment >

[jira] [Updated] (KAFKA-10185) Streams should log summarized restoration information at info level

[ https://issues.apache.org/jira/browse/KAFKA-10185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-10185: -- Fix Version/s: (was: 2.6.0) > Streams should log summarized restoration information at inf

[jira] [Commented] (KAFKA-9458) Kafka crashed in windows environment

[ https://issues.apache.org/jira/browse/KAFKA-9458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17144370#comment-17144370 ] Randall Hauch commented on KAFKA-9458: -- Since this is not a blocker issue, as part o

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

[ https://issues.apache.org/jira/browse/KAFKA-10166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17144358#comment-17144358 ] Randall Hauch commented on KAFKA-10166: --- [~ableegoldman], [~cadonna]: Do we want t

[jira] [Commented] (KAFKA-10143) Can no longer change replication throttle with reassignment tool

[ https://issues.apache.org/jira/browse/KAFKA-10143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17144357#comment-17144357 ] Randall Hauch commented on KAFKA-10143: --- [~hachikuji]: do we want to continue trea

[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=17144355#comment-17144355 ] Randall Hauch commented on KAFKA-10134: --- [~guozhang], [~ijuma], [~seanguo]: what's

[jira] [Commented] (KAFKA-10017) Flaky Test EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta

[ https://issues.apache.org/jira/browse/KAFKA-10017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17144352#comment-17144352 ] Randall Hauch commented on KAFKA-10017: --- [~vvcephei], [~ableegoldman]: what's the

[jira] [Commented] (KAFKA-8073) Transient failure in kafka.api.UserQuotaTest.testThrottledProducerConsumer

[ https://issues.apache.org/jira/browse/KAFKA-8073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17144349#comment-17144349 ] Randall Hauch commented on KAFKA-8073: -- Since this is not a blocker issue, as part o

[jira] [Updated] (KAFKA-8073) Transient failure in kafka.api.UserQuotaTest.testThrottledProducerConsumer

[ https://issues.apache.org/jira/browse/KAFKA-8073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8073: - Fix Version/s: (was: 2.6.0) 2.6.1 2.7.0 > Transient fai

[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 ] Randall Hauch updated KAFKA-10135: -- Fix Version/s: 2.6.0 > Extract Task#executeAndMaybeSwallow to be a general utility function in

[jira] [Updated] (KAFKA-7964) Flaky Test ConsumerBounceTest#testConsumerReceivesFatalExceptionWhenGroupPassesMaxSize

[ https://issues.apache.org/jira/browse/KAFKA-7964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-7964: - Fix Version/s: (was: 2.6.0) 2.6.1 2.7.0 Since this is n

[jira] [Updated] (KAFKA-8085) Flaky Test ResetConsumerGroupOffsetTest#testResetOffsetsByDuration

[ https://issues.apache.org/jira/browse/KAFKA-8085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8085: - Fix Version/s: (was: 2.6.0) 2.6.1 2.7.0 Since this is n

[jira] [Updated] (KAFKA-7540) Flaky Test ConsumerBounceTest#testClose

[ https://issues.apache.org/jira/browse/KAFKA-7540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-7540: - Fix Version/s: (was: 2.6.0) 2.6.1 2.7.0 Since this is n

[jira] [Updated] (KAFKA-8140) Flaky Test SaslSslAdminClientIntegrationTest#testDescribeAndAlterConfigs

[ https://issues.apache.org/jira/browse/KAFKA-8140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8140: - Fix Version/s: (was: 2.6.0) 2.6.1 2.7.0 Since this is n

[jira] [Updated] (KAFKA-8250) Flaky Test DelegationTokenEndToEndAuthorizationTest#testProduceConsumeViaAssign

[ https://issues.apache.org/jira/browse/KAFKA-8250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8250: - Fix Version/s: (was: 2.6.0) 2.6.1 2.7.0 Since this is n

[jira] [Updated] (KAFKA-8138) Flaky Test PlaintextConsumerTest#testFetchRecordLargerThanFetchMaxBytes

[ https://issues.apache.org/jira/browse/KAFKA-8138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8138: - Fix Version/s: (was: 2.6.0) 2.6.1 2.7.0 Since this is n

[jira] [Updated] (KAFKA-7947) Flaky Test EpochDrivenReplicationProtocolAcceptanceTest#shouldFollowLeaderEpochBasicWorkflow

[ https://issues.apache.org/jira/browse/KAFKA-7947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-7947: - Fix Version/s: (was: 2.6.0) 2.6.1 2.7.0 Since this is n

[jira] [Updated] (KAFKA-7969) Flaky Test DescribeConsumerGroupTest#testDescribeOffsetsOfExistingGroupWithNoMembers

[ https://issues.apache.org/jira/browse/KAFKA-7969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-7969: - Fix Version/s: (was: 2.6.0) 2.6.1 2.7.0 Since this is n

[jira] [Updated] (KAFKA-8267) Flaky Test SaslAuthenticatorTest#testUserCredentialsUnavailableForScramMechanism

[ https://issues.apache.org/jira/browse/KAFKA-8267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8267: - Fix Version/s: (was: 2.6.0) 2.6.1 2.7.0 Since this is n

[jira] [Updated] (KAFKA-8268) Flaky Test SaslSslAdminIntegrationTest#testSeekAfterDeleteRecords

[ https://issues.apache.org/jira/browse/KAFKA-8268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8268: - Fix Version/s: (was: 2.6.0) 2.6.1 2.7.0 Since this is n

[jira] [Updated] (KAFKA-8269) Flaky Test TopicCommandWithAdminClientTest#testDescribeUnderMinIsrPartitionsMixed

[ https://issues.apache.org/jira/browse/KAFKA-8269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8269: - Fix Version/s: (was: 2.6.0) 2.6.1 2.7.0 Since this is n

[jira] [Updated] (KAFKA-8033) Flaky Test PlaintextConsumerTest#testFetchInvalidOffset

[ https://issues.apache.org/jira/browse/KAFKA-8033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8033: - Fix Version/s: (was: 2.6.0) 2.6.1 2.7.0 Since this is n

[jira] [Updated] (KAFKA-8113) Flaky Test ListOffsetsRequestTest#testResponseIncludesLeaderEpoch

[ https://issues.apache.org/jira/browse/KAFKA-8113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8113: - Fix Version/s: (was: 2.6.0) 2.6.1 2.7.0 Since this is n

[jira] [Updated] (KAFKA-7957) Flaky Test DynamicBrokerReconfigurationTest#testMetricsReporterUpdate

[ https://issues.apache.org/jira/browse/KAFKA-7957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-7957: - Fix Version/s: (was: 2.6.0) 2.6.1 2.7.0 Since this is n

[jira] [Updated] (KAFKA-8115) Flaky Test CoordinatorTest#testTaskRequestWithOldStartMsGetsUpdated

[ https://issues.apache.org/jira/browse/KAFKA-8115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8115: - Fix Version/s: (was: 2.6.0) 2.6.1 2.7.0 Since this is n

[jira] [Updated] (KAFKA-8082) Flaky Test ProducerFailureHandlingTest#testNotEnoughReplicasAfterBrokerShutdown

[ https://issues.apache.org/jira/browse/KAFKA-8082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8082: - Fix Version/s: (was: 2.6.0) 2.6.1 2.7.0 Since this is n

[jira] [Updated] (KAFKA-8015) Flaky Test SaslGssapiSslEndToEndAuthorizationTest#testProduceConsumeTopicAutoCreateTopicCreateAcl

[ https://issues.apache.org/jira/browse/KAFKA-8015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8015: - Fix Version/s: (was: 2.6.0) 2.6.1 2.7.0 Since this is n

[jira] [Updated] (KAFKA-8084) Flaky Test DescribeConsumerGroupTest#testDescribeMembersOfExistingGroupWithNoMembers

[ https://issues.apache.org/jira/browse/KAFKA-8084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8084: - Fix Version/s: (was: 2.6.0) 2.6.1 2.7.0 Since this is n

[jira] [Updated] (KAFKA-8141) Flaky Test FetchRequestDownConversionConfigTest#testV1FetchWithDownConversionDisabled

[ https://issues.apache.org/jira/browse/KAFKA-8141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8141: - Fix Version/s: (was: 2.6.0) 2.6.1 2.7.0 Since this is n

[jira] [Updated] (KAFKA-7988) Flaky Test DynamicBrokerReconfigurationTest#testThreadPoolResize

[ https://issues.apache.org/jira/browse/KAFKA-7988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-7988: - Fix Version/s: (was: 2.6.0) 2.6.1 2.7.0 Since this is n

[jira] [Updated] (KAFKA-8329) Flaky Test LogOffsetTest#testEmptyLogsGetOffsets

[ https://issues.apache.org/jira/browse/KAFKA-8329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8329: - Fix Version/s: (was: 2.6.0) 2.6.1 2.7.0 Since this is n

[jira] [Updated] (KAFKA-8059) Flaky Test DynamicConnectionQuotaTest #testDynamicConnectionQuota

[ https://issues.apache.org/jira/browse/KAFKA-8059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8059: - Fix Version/s: (was: 2.6.0) 2.6.1 2.7.0 Since this is n

[jira] [Updated] (KAFKA-8303) Flaky Test SaslSslAdminClientIntegrationTest#testLogStartOffsetCheckpoint

[ https://issues.apache.org/jira/browse/KAFKA-8303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8303: - Fix Version/s: (was: 2.6.0) 2.6.1 2.7.0 Since this is n

[jira] [Updated] (KAFKA-8110) Flaky Test DescribeConsumerGroupTest#testDescribeMembersWithConsumersWithoutAssignedPartitions

[ https://issues.apache.org/jira/browse/KAFKA-8110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8110: - Fix Version/s: (was: 2.6.0) 2.6.1 2.7.0 Since this is n

[jira] [Updated] (KAFKA-8068) Flaky Test DescribeConsumerGroupTest#testDescribeMembersOfExistingGroup

[ https://issues.apache.org/jira/browse/KAFKA-8068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8068: - Fix Version/s: (was: 2.6.0) 2.6.1 2.7.0 Since this is n

[jira] [Updated] (KAFKA-8064) Flaky Test DeleteTopicTest #testRecreateTopicAfterDeletion

[ https://issues.apache.org/jira/browse/KAFKA-8064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8064: - Fix Version/s: (was: 2.6.0) 2.6.1 2.7.0 Since this is n

[jira] [Updated] (KAFKA-8701) Flaky Test SaslSslAdminClientIntegrationTest#testDescribeConfigsForTopic

[ https://issues.apache.org/jira/browse/KAFKA-8701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8701: - Fix Version/s: (was: 2.6.0) 2.6.1 2.7.0 Since this is n

[jira] [Updated] (KAFKA-8133) Flaky Test MetadataRequestTest#testNoTopicsRequest

[ https://issues.apache.org/jira/browse/KAFKA-8133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8133: - Fix Version/s: (was: 2.6.0) 2.6.1 2.7.0 Since this is n

[jira] [Updated] (KAFKA-8075) Flaky Test GroupAuthorizerIntegrationTest#testTransactionalProducerTopicAuthorizationExceptionInCommit

[ https://issues.apache.org/jira/browse/KAFKA-8075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8075: - Fix Version/s: (was: 2.6.0) 2.6.1 2.7.0 Since this is n

  1   2   3   >