[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

[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-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] [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] [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] [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

[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) {

[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) {

[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] 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

[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

[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

[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

[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) {

[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] 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_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_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_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] 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

[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] 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

[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] 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] 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] 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] 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

[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] 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-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

[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=17623898#comment-17623898 ] Francesco Guardiani commented on KAFKA-10523: - I opened a similar issue in l

[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

[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

[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] 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

[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] 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_r1004412949 ## connect/runtime/src/test/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerderTest.java: ## @@ -218,43 +229,37 @@ public void testCreateConnectorAlrea

[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] 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 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] 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

[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

[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 > > >

[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

[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] 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] 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] 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] 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] 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