[GitHub] [kafka] lucasbru commented on pull request #12760: KAFKA-14309: FK join upgrades not tested with DEV_VERSION

lucasbru commented on PR #12760: URL: https://github.com/apache/kafka/pull/12760#issuecomment-1290109943 System test run https://jenkins.confluent.io/job/system-test-kafka-branch-builder/5183 Only failure is unrelated kafkatest.tests.core.round_trip_fault_test.RoundTripFaultTe

[GitHub] [kafka] sudeshwasnik opened a new pull request, #12784: Do not perform prodcuerCommit on serialization error

sudeshwasnik opened a new pull request, #12784: URL: https://github.com/apache/kafka/pull/12784 *More detailed description of your change, if necessary. The PR title and PR message become the squashed commit message, so use a separate comment to ping reviewers.* *Summary of te

[GitHub] [kafka] shekhar-rajak commented on a diff in pull request #12777: Replace EasyMock and PowerMock with Mockito - TimeOrderedWindowStoreTest

shekhar-rajak commented on code in PR #12777: URL: https://github.com/apache/kafka/pull/12777#discussion_r1004126495 ## streams/src/test/java/org/apache/kafka/streams/state/internals/TimeOrderedWindowStoreTest.java: ## @@ -1166,58 +1164,47 @@ public void shouldNotThrowInvalidBa

[GitHub] [kafka] omkreddy opened a new pull request, #12785: Test PR

omkreddy opened a new pull request, #12785: URL: https://github.com/apache/kafka/pull/12785 *More detailed description of your change, if necessary. The PR title and PR message become the squashed commit message, so use a separate comment to ping reviewers.* *Summary of testin

[GitHub] [kafka] omkreddy opened a new pull request, #12786: MINOR: Fix rat task verbose output

omkreddy opened a new pull request, #12786: URL: https://github.com/apache/kafka/pull/12786 Currently we are setting non-existing verbose field of Rat task. Fixed the issue by calling correct Rat task method. -- This is an automated message from the Apache Git Service. To respond to the m

[GitHub] [kafka] dajac commented on a diff in pull request #12783: KAFKA-14334: complete delayed purgatory after replication

dajac commented on code in PR #12783: URL: https://github.com/apache/kafka/pull/12783#discussion_r1004162782 ## core/src/test/scala/integration/kafka/server/FetchFromFollowerIntegrationTest.scala: ## @@ -0,0 +1,106 @@ +/** + * Licensed to the Apache Software Foundation (ASF) und

[GitHub] [kafka] lucasbru commented on a diff in pull request #12771: KAFKA-14299: Handle TaskCorruptedException during initialization

lucasbru commented on code in PR #12771: URL: https://github.com/apache/kafka/pull/12771#discussion_r1004177386 ## streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java: ## @@ -1435,6 +1435,31 @@ public void shouldRethrowTaskCorruptedExceptionF

[jira] [Resolved] (KAFKA-14331) Upgrade to Scala 2.13.10

[ https://issues.apache.org/jira/browse/KAFKA-14331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Viktor Somogyi-Vass resolved KAFKA-14331. - Resolution: Duplicate > Upgrade to Scala 2.13.10 > > >

[jira] [Commented] (KAFKA-14331) Upgrade to Scala 2.13.10

[ https://issues.apache.org/jira/browse/KAFKA-14331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17623677#comment-17623677 ] Viktor Somogyi-Vass commented on KAFKA-14331: - Thanks [~mimaison], I'll reso

[GitHub] [kafka] lucasbru commented on a diff in pull request #12771: KAFKA-14299: Handle TaskCorruptedException during initialization

lucasbru commented on code in PR #12771: URL: https://github.com/apache/kafka/pull/12771#discussion_r1004217492 ## streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java: ## @@ -810,10 +810,19 @@ private void transitRestoredTaskToRunning(final Task t

[GitHub] [kafka] omkreddy merged pull request #12786: MINOR: Fix rat task verbose output config

omkreddy merged PR #12786: URL: https://github.com/apache/kafka/pull/12786 -- 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 the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache

[GitHub] [kafka] omkreddy closed pull request #12785: Test PR

omkreddy closed pull request #12785: Test PR URL: https://github.com/apache/kafka/pull/12785 -- 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 the specific comment. To unsubscribe, e-mail: jira-unsubs

[GitHub] [kafka] omkreddy commented on pull request #12675: KAFKA-14256: Upgrade from Scala 2.13.8 to 2.13.10

omkreddy commented on PR #12675: URL: https://github.com/apache/kafka/pull/12675#issuecomment-1290366042 @mdedetrich Thanks for the PR. I have run this PR with rat verbose [output bug fix ](https://github.com/apache/kafka/pull/12786) Results are (https://github.com/apache/kafka/pull/

[GitHub] [kafka] mdedetrich commented on a diff in pull request #12728: KAFKA-14132; Replace EasyMock with Mockito in StandaloneHerderTest

mdedetrich commented on code in PR #12728: URL: https://github.com/apache/kafka/pull/12728#discussion_r1004412949 ## connect/runtime/src/test/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerderTest.java: ## @@ -218,43 +229,37 @@ public void testCreateConnectorAlrea

[GitHub] [kafka] mdedetrich commented on a diff in pull request #12728: KAFKA-14132; Replace EasyMock with Mockito in StandaloneHerderTest

mdedetrich commented on code in PR #12728: URL: https://github.com/apache/kafka/pull/12728#discussion_r1004423779 ## connect/runtime/src/test/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerderTest.java: ## @@ -319,35 +318,28 @@ public void testRestartConnectorNewT

[GitHub] [kafka] mdedetrich commented on a diff in pull request #12728: KAFKA-14132; Replace EasyMock with Mockito in StandaloneHerderTest

mdedetrich commented on code in PR #12728: URL: https://github.com/apache/kafka/pull/12728#discussion_r1004427401 ## connect/runtime/src/test/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerderTest.java: ## @@ -123,91 +134,91 @@ private enum SourceSink { priva

[GitHub] [kafka] vamossagar12 commented on a diff in pull request #12561: KAFKA-12495: Exponential backoff retry to prevent rebalance storms when worker joins after revoking rebalance

vamossagar12 commented on code in PR #12561: URL: https://github.com/apache/kafka/pull/12561#discussion_r1004454702 ## connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinatorIncrementalTest.java: ## @@ -517,13 +517,13 @@ public void testTaskA

[jira] [Commented] (KAFKA-14329) KafkaAdminClient#listOffsets should query by partition dimension

[ https://issues.apache.org/jira/browse/KAFKA-14329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17623818#comment-17623818 ] Deng Ziming commented on KAFKA-14329: - [~shizhenzhen] I think you submit your PR dir

[GitHub] [kafka] omkreddy merged pull request #12779: MINOR: Fix allDepInsight build task with gradle 7.5

omkreddy merged PR #12779: URL: https://github.com/apache/kafka/pull/12779 -- 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 the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache

[GitHub] [kafka] mdedetrich commented on a diff in pull request #12728: KAFKA-14132; Replace EasyMock with Mockito in StandaloneHerderTest

mdedetrich commented on code in PR #12728: URL: https://github.com/apache/kafka/pull/12728#discussion_r1004507344 ## connect/runtime/src/test/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerderTest.java: ## @@ -123,91 +134,91 @@ private enum SourceSink { priva

[GitHub] [kafka] mdedetrich commented on a diff in pull request #12728: KAFKA-14132; Replace EasyMock with Mockito in StandaloneHerderTest

mdedetrich commented on code in PR #12728: URL: https://github.com/apache/kafka/pull/12728#discussion_r1004507344 ## connect/runtime/src/test/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerderTest.java: ## @@ -123,91 +134,91 @@ private enum SourceSink { priva

[GitHub] [kafka] mdedetrich commented on a diff in pull request #12728: KAFKA-14132; Replace EasyMock with Mockito in StandaloneHerderTest

mdedetrich commented on code in PR #12728: URL: https://github.com/apache/kafka/pull/12728#discussion_r1004507344 ## connect/runtime/src/test/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerderTest.java: ## @@ -123,91 +134,91 @@ private enum SourceSink { priva

[GitHub] [kafka] mdedetrich commented on a diff in pull request #12728: KAFKA-14132; Replace EasyMock with Mockito in StandaloneHerderTest

mdedetrich commented on code in PR #12728: URL: https://github.com/apache/kafka/pull/12728#discussion_r1004507344 ## connect/runtime/src/test/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerderTest.java: ## @@ -123,91 +134,91 @@ private enum SourceSink { priva

[jira] [Commented] (KAFKA-10523) Allow to provide producer ID

[ https://issues.apache.org/jira/browse/KAFKA-10523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17623898#comment-17623898 ] Francesco Guardiani commented on KAFKA-10523: - I opened a similar issue in l

[jira] [Assigned] (KAFKA-14256) Update to Scala 2.13.9

[ https://issues.apache.org/jira/browse/KAFKA-14256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-14256: - Assignee: Matthew de Detrich > Update to Scala 2.13.9 > -- > >

[jira] [Commented] (KAFKA-10523) Allow to provide producer ID

[ https://issues.apache.org/jira/browse/KAFKA-10523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17623902#comment-17623902 ] Till Rohrmann commented on KAFKA-10523: --- Being able to provide the producer ID and

[GitHub] [kafka] philipnee commented on a diff in pull request #12775: KAFKA-14247: add handler impl to the prototype

philipnee commented on code in PR #12775: URL: https://github.com/apache/kafka/pull/12775#discussion_r1004687696 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/DefaultBackgroundThread.java: ## @@ -64,27 +64,6 @@ public class DefaultBackgroundThread extends

[jira] [Commented] (KAFKA-12199) Migrate connect:runtime module to JUnit 5

[ https://issues.apache.org/jira/browse/KAFKA-12199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17623917#comment-17623917 ] jackwangcs commented on KAFKA-12199: Hi [~chia7712] , are you still working on this?

[GitHub] [kafka] dajac commented on a diff in pull request #12149: KAFKA-13668: Retry upon missing initProducerId due to authorization error

dajac commented on code in PR #12149: URL: https://github.com/apache/kafka/pull/12149#discussion_r1004739130 ## core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala: ## @@ -2236,6 +2236,30 @@ class AuthorizerIntegrationTest extends BaseRequestTest { ass

[GitHub] [kafka] philipnee commented on a diff in pull request #12149: KAFKA-13668: Retry upon missing initProducerId due to authorization error

philipnee commented on code in PR #12149: URL: https://github.com/apache/kafka/pull/12149#discussion_r1004752898 ## clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java: ## @@ -996,20 +1010,21 @@ private void ensureTransactional() { }

[GitHub] [kafka] vvcephei commented on pull request #12775: KAFKA-14247: add handler impl to the prototype

vvcephei commented on PR #12775: URL: https://github.com/apache/kafka/pull/12775#issuecomment-1290934035 I don't see how it could be related, but Gradle got a bunch of OOMEs on your last test run, so I kicked it off again. -- This is an automated message from the Apache Git Service. To re

[GitHub] [kafka] scott-hendricks closed pull request #7487: KAFKA-9010: Add PartitionGrower, Support partition requery in ProduceBench test.

scott-hendricks closed pull request #7487: KAFKA-9010: Add PartitionGrower, Support partition requery in ProduceBench test. URL: https://github.com/apache/kafka/pull/7487 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use th

[GitHub] [kafka] functioner commented on pull request #11520: KAFKA-13468: Consumers may hang because IOException in Log# does not trigger KafkaStorageException

functioner commented on PR #11520: URL: https://github.com/apache/kafka/pull/11520#issuecomment-1290981297 I have updated the patch. It seems `LogDirFailureChannel` requires some `logDir` to use, which is absent here and I currently I don't have idea about this. @hachikuji What do you thin

[GitHub] [kafka] gharris1727 commented on a diff in pull request #12781: KAFKA-14132; Replace EasyMock with Mockito in KafkaBasedLogTest

gharris1727 commented on code in PR #12781: URL: https://github.com/apache/kafka/pull/12781#discussion_r1004923625 ## connect/runtime/src/test/java/org/apache/kafka/connect/util/KafkaBasedLogTest.java: ## @@ -547,32 +540,22 @@ public void testReadEndOffsetsUsingAdminThatFailsWi

[jira] [Commented] (KAFKA-14326) kafka-application-reset-tool should accept spaces between input/intermediate topics

[ https://issues.apache.org/jira/browse/KAFKA-14326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624027#comment-17624027 ] Richard Joerger commented on KAFKA-14326: - [~mallwoodrbi], would you be able to

[GitHub] [kafka] Moovlin opened a new pull request, #12787: [WIP][KAFKA-14326] Removes excess white space surrounding topic input for S

Moovlin opened a new pull request, #12787: URL: https://github.com/apache/kafka/pull/12787 *More detailed description of your change, if necessary. The PR title and PR message become the squashed commit message, so use a separate comment to ping reviewers.* The goal of the change

[GitHub] [kafka] jolshan commented on a diff in pull request #12149: KAFKA-13668: Retry upon missing initProducerId due to authorization error

jolshan commented on code in PR #12149: URL: https://github.com/apache/kafka/pull/12149#discussion_r1004941219 ## clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java: ## @@ -618,7 +618,8 @@ private TransactionManager configureTransactionState(ProducerConf

[GitHub] [kafka] jolshan commented on a diff in pull request #12149: KAFKA-13668: Retry upon missing initProducerId due to authorization error

jolshan commented on code in PR #12149: URL: https://github.com/apache/kafka/pull/12149#discussion_r1004941219 ## clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java: ## @@ -618,7 +618,8 @@ private TransactionManager configureTransactionState(ProducerConf

[GitHub] [kafka] jolshan commented on a diff in pull request #12149: KAFKA-13668: Retry upon missing initProducerId due to authorization error

jolshan commented on code in PR #12149: URL: https://github.com/apache/kafka/pull/12149#discussion_r1004944699 ## clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java: ## @@ -618,7 +618,8 @@ private TransactionManager configureTransactionState(ProducerConf

[GitHub] [kafka] jolshan commented on a diff in pull request #12149: KAFKA-13668: Retry upon missing initProducerId due to authorization error

jolshan commented on code in PR #12149: URL: https://github.com/apache/kafka/pull/12149#discussion_r1004948547 ## clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java: ## @@ -155,7 +155,7 @@ private enum State { private boolean isTra

[GitHub] [kafka] jolshan commented on a diff in pull request #12149: KAFKA-13668: Retry upon missing initProducerId due to authorization error

jolshan commented on code in PR #12149: URL: https://github.com/apache/kafka/pull/12149#discussion_r1004948547 ## clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java: ## @@ -155,7 +155,7 @@ private enum State { private boolean isTra

[GitHub] [kafka] jolshan commented on a diff in pull request #12149: KAFKA-13668: Retry upon missing initProducerId due to authorization error

jolshan commented on code in PR #12149: URL: https://github.com/apache/kafka/pull/12149#discussion_r1004955636 ## clients/src/test/java/org/apache/kafka/clients/producer/KafkaProducerTest.java: ## @@ -1237,6 +1238,34 @@ public void testInitTransactionWhileThrottled() {

[GitHub] [kafka] jolshan commented on a diff in pull request #12149: KAFKA-13668: Retry upon missing initProducerId due to authorization error

jolshan commented on code in PR #12149: URL: https://github.com/apache/kafka/pull/12149#discussion_r1004958467 ## core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala: ## @@ -2236,6 +2236,30 @@ class AuthorizerIntegrationTest extends BaseRequestTest { a

[GitHub] [kafka] gharris1727 commented on a diff in pull request #12544: KAFKA-14098: Add meaningful default client IDs for Connect workers

gharris1727 commented on code in PR #12544: URL: https://github.com/apache/kafka/pull/12544#discussion_r1004961482 ## connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectDistributed.java: ## @@ -106,6 +108,7 @@ public Connect startConnect(Map workerProps) {

[jira] [Commented] (KAFKA-14023) MirrorCheckpointTask.syncGroupOffset does not have to check if translated offset from upstream is smaller than the current consumer offset

[ https://issues.apache.org/jira/browse/KAFKA-14023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624052#comment-17624052 ] Greg Harris commented on KAFKA-14023: - [~Justinwins] I believe the motivation for th

[jira] [Resolved] (KAFKA-14023) MirrorCheckpointTask.syncGroupOffset does not have to check if translated offset from upstream is smaller than the current consumer offset

[ https://issues.apache.org/jira/browse/KAFKA-14023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-14023. - Resolution: Won't Do > MirrorCheckpointTask.syncGroupOffset does not have to check if translate

[GitHub] [kafka] philipnee opened a new pull request, #12788: [Test]Testing Gradle OOM

philipnee opened a new pull request, #12788: URL: https://github.com/apache/kafka/pull/12788 *More detailed description of your change, if necessary. The PR title and PR message become the squashed commit message, so use a separate comment to ping reviewers.* *Summary of testi

[GitHub] [kafka] gharris1727 opened a new pull request, #12789: KAFKA-13989: Errors while evaluating connector type should return UNKNOWN

gharris1727 opened a new pull request, #12789: URL: https://github.com/apache/kafka/pull/12789 Signed-off-by: Greg Harris https://issues.apache.org/jira/browse/KAFKA-13989 This method is used by the REST API in the `GET /connectors?expand=info,status` call. In cases where a

[jira] [Commented] (KAFKA-14326) kafka-application-reset-tool should accept spaces between input/intermediate topics

[ https://issues.apache.org/jira/browse/KAFKA-14326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624070#comment-17624070 ] Matt Allwood commented on KAFKA-14326: -- Pretty much, just our app is a bit of a beh

[GitHub] [kafka] soarez commented on a diff in pull request #12789: KAFKA-13989: Errors while evaluating connector type should return UNKNOWN

soarez commented on code in PR #12789: URL: https://github.com/apache/kafka/pull/12789#discussion_r1005027030 ## connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractHerder.java: ## @@ -691,7 +691,14 @@ protected Connector getConnector(String connType) {

[GitHub] [kafka] C0urante commented on a diff in pull request #12544: KAFKA-14098: Add meaningful default client IDs for Connect workers

C0urante commented on code in PR #12544: URL: https://github.com/apache/kafka/pull/12544#discussion_r1005090102 ## connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectDistributed.java: ## @@ -106,6 +108,7 @@ public Connect startConnect(Map workerProps) {

[jira] [Created] (KAFKA-14337) bugs kafka 3.3.1 create topic after delete topic

thanhnd96 created KAFKA-14337: - Summary: bugs kafka 3.3.1 create topic after delete topic Key: KAFKA-14337 URL: https://issues.apache.org/jira/browse/KAFKA-14337 Project: Kafka Issue Type: Bug

[jira] [Assigned] (KAFKA-14337) bugs kafka 3.3.1 create topic after delete topic

[ https://issues.apache.org/jira/browse/KAFKA-14337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-14337: - Assignee: Luke Chen > bugs kafka 3.3.1 create topic after delete topic > --

[jira] [Commented] (KAFKA-14337) bugs kafka 3.3.1 create topic after delete topic

[ https://issues.apache.org/jira/browse/KAFKA-14337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624189#comment-17624189 ] Luke Chen commented on KAFKA-14337: --- Nice find! Investigating!   > bugs kafka 3.3.1

[jira] [Updated] (KAFKA-14324) [CVE-2018-25032] introduced by rocksdbjni:6.29.4.1

[ https://issues.apache.org/jira/browse/KAFKA-14324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] VZhang updated KAFKA-14324: --- Attachment: 6.29.4.1_to_7.1.2_compat_report.html > [CVE-2018-25032] introduced by rocksdbjni:6.29.4.1 >

[jira] [Updated] (KAFKA-14324) [CVE-2018-25032] introduced by rocksdbjni:6.29.4.1

[ https://issues.apache.org/jira/browse/KAFKA-14324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] VZhang updated KAFKA-14324: --- Attachment: 6.29.4.1_to_7.7.3_compat_report.html > [CVE-2018-25032] introduced by rocksdbjni:6.29.4.1 >

[jira] [Updated] (KAFKA-14337) bugs kafka 3.3.1 create topic after delete topic

[ https://issues.apache.org/jira/browse/KAFKA-14337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] thanhnd96 updated KAFKA-14337: -- Description: Hi admin, My issue is after i create topic like topic.AAA or Topic.AAA.01 then delete 1