Re: [PR] KAFKA-16954: fix consumer close to release assignment in background [kafka]

2024-06-17 Thread via GitHub
lucasbru commented on PR #16376: URL: https://github.com/apache/kafka/pull/16376#issuecomment-2175272676 @jlprat Fix for blocker KAFKA-16954 merged to 3.8 branch -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

Re: [PR] KAFKA-16954: fix consumer close to release assignment in background [kafka]

2024-06-17 Thread via GitHub
lucasbru merged PR #16376: URL: https://github.com/apache/kafka/pull/16376 -- 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

[PR] ConfigCommand should not allow to define both `entity-default` and `entity-name` [kafka]

2024-06-17 Thread via GitHub
m1a2st opened a new pull request, #16381: URL: https://github.com/apache/kafka/pull/16381 https://issues.apache.org/jira/browse/KAFKA-16959 add new check and test fot can't allow both parameter waiting for https://github.com/apache/kafka/pull/16317 ### Committer Checklist (ex

[PR] use the dsl store supplier for fkj subscriptions [kafka]

2024-06-17 Thread via GitHub
rodesai opened a new pull request, #16380: URL: https://github.com/apache/kafka/pull/16380 (no comment) -- 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-ma

[jira] [Updated] (KAFKA-16480) ListOffsets change should have an associated API/IBP version update

2024-06-17 Thread Josep Prat (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Josep Prat updated KAFKA-16480: --- Fix Version/s: 3.8.0 > ListOffsets change should have an associated API/IBP version update > ---

[jira] [Updated] (KAFKA-16480) ListOffsets change should have an associated API/IBP version update

2024-06-17 Thread Josep Prat (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Josep Prat updated KAFKA-16480: --- Affects Version/s: 3.8.0 > ListOffsets change should have an associated API/IBP version update > ---

Re: [PR] KAFKA-16968: Make 3.8-IV0 a stable MetadataVersion and create 3.9-IV0 [kafka]

2024-06-17 Thread via GitHub
jlprat commented on PR #16347: URL: https://github.com/apache/kafka/pull/16347#issuecomment-2175231482 hi @junrao I marked https://issues.apache.org/jira/projects/KAFKA/issues/KAFKA-16480 as a blocker for 3.8 -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Updated] (KAFKA-16480) ListOffsets change should have an associated API/IBP version update

2024-06-17 Thread Josep Prat (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Josep Prat updated KAFKA-16480: --- Priority: Blocker (was: Major) > ListOffsets change should have an associated API/IBP version updat

Re: [PR] KAFKA-16988: add 1 more node for test_exactly_once_source system test [kafka]

2024-06-17 Thread via GitHub
showuon commented on PR #16379: URL: https://github.com/apache/kafka/pull/16379#issuecomment-2175200173 @soarez, this is found while running system test in v3.7.1 RC build. We should add this into RC2. cc @jlprat , this also impacts v3.8.0. We should back port this fix into v3.8 branch.

[PR] KAFKA-16988: add 1 more node for test_exactly_once_source system test [kafka]

2024-06-17 Thread via GitHub
showuon opened a new pull request, #16379: URL: https://github.com/apache/kafka/pull/16379 `ducktape.cluster.node_container.InsufficientResourcesError: linux nodes requested: 1. linux nodes available: 0` thrown when running `ConnectDistributedTest#test_exactly_once_source` system test. Addi

[jira] [Updated] (KAFKA-16982) Docker Official Image Build and Test

2024-06-17 Thread Krish Vora (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Krish Vora updated KAFKA-16982: --- Description: Provide the image type and kafka version to {{Docker Official Image Build Test}} workf

[jira] [Updated] (KAFKA-16983) Generate the PR for Docker Official Images repo

2024-06-17 Thread Krish Vora (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Krish Vora updated KAFKA-16983: --- Description: # Run the {{docker/generate_kafka_pr_template.py}} script from trunk, by providing it

[jira] [Updated] (KAFKA-16983) Generate the PR for Docker Official Images repo

2024-06-17 Thread Krish Vora (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Krish Vora updated KAFKA-16983: --- Description: # Run the {{docker/generate_kafka_pr_template.py}} script from trunk, by providing it

[jira] [Updated] (KAFKA-16980) Extract docker official image artifact

2024-06-17 Thread Krish Vora (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Krish Vora updated KAFKA-16980: --- Description: # Run the {{docker/extract_docker_official_image_artifact.py}} script, by providing it

[jira] [Updated] (KAFKA-16979) Prepare Docker Official Image Source for 3.7.0 release

2024-06-17 Thread Krish Vora (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Krish Vora updated KAFKA-16979: --- Description: Provide the image type and kafka version to {{Docker Prepare Docker Official Image Sou

[jira] [Updated] (KAFKA-16980) Extract docker official image artifact

2024-06-17 Thread Krish Vora (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Krish Vora updated KAFKA-16980: --- Description: # Run the {{docker/extract_docker_official_image_artifact.py}} script, by providing it

Re: [PR] KAFKA-16977: Reapply dynamic remote configs after broker restart [kafka]

2024-06-17 Thread via GitHub
satishd commented on PR #16353: URL: https://github.com/apache/kafka/pull/16353#issuecomment-2175033037 Thanks @jlprat , merged to 3.8. -- 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 specifi

Re: [PR] KAFKA-5072[WIP]: Kafka topics should allow custom metadata configs within some config namespace [kafka]

2024-06-17 Thread via GitHub
wspragg commented on PR #2873: URL: https://github.com/apache/kafka/pull/2873#issuecomment-2175031620 Really important feature and been waiting for way to long, can we get this released. -- This is an automated message from the Apache Git Service. To respond to the message, please log on

Re: [PR] KAFKA-16803: Update ShadowJavaPlugin [kafka]

2024-06-17 Thread via GitHub
Nancy-ksolves commented on PR #16295: URL: https://github.com/apache/kafka/pull/16295#issuecomment-2175002646 So maybe we can consider this as a temporary solution and then think about removing that altogether later. Thoughts? -- This is an automated message from the Apache Git Se

Re: [PR] KAFKA-16977: Reapply dynamic remote configs after broker restart [kafka]

2024-06-17 Thread via GitHub
jlprat commented on PR #16353: URL: https://github.com/apache/kafka/pull/16353#issuecomment-2174993552 Yes, it can be ported to 3.8. Thanks @satishd -- 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

Re: [PR] KAFKA-16977: Reapply dynamic remote configs after broker restart [kafka]

2024-06-17 Thread via GitHub
satishd commented on PR #16353: URL: https://github.com/apache/kafka/pull/16353#issuecomment-2174953555 @jlprat This is a bug fix that should be pushed to 3.8. wdyt? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

Re: [PR] KAFKA-16977: Reapply dynamic remote configs after broker restart [kafka]

2024-06-17 Thread via GitHub
satishd merged PR #16353: URL: https://github.com/apache/kafka/pull/16353 -- 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.

Re: [PR] KAFKA-16977: Reapply dynamic remote configs after broker restart [kafka]

2024-06-17 Thread via GitHub
satishd commented on PR #16353: URL: https://github.com/apache/kafka/pull/16353#issuecomment-2174944290 A few unrelated test failures, merging it to trunk for now. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

Re: [PR] KAFKA-16958 add STRICT_STUBS to EndToEndLatencyTest, OffsetCommitCallbackInvokerTest, ProducerPerformanceTest, and TopologyTest [kafka]

2024-06-17 Thread via GitHub
dujian0068 commented on PR #16348: URL: https://github.com/apache/kafka/pull/16348#issuecomment-2174890810 @chia7712 already edited -- 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 specifi

[jira] [Resolved] (KAFKA-16969) KRaft unable to upgrade to v3.7.1 and later when multiple log dir is set

2024-06-17 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-16969. --- Fix Version/s: 3.8.0 3.7.1 Assignee: Igor Soarez Resolution: Fixed

Re: [PR] KAFKA-16969: Log error if config conficts with MV [kafka]

2024-06-17 Thread via GitHub
showuon commented on PR #16366: URL: https://github.com/apache/kafka/pull/16366#issuecomment-2174883941 Backported to 3.7/3.8 branches. -- 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 specif

Re: [PR] KAFKA-16969: Log error if config conficts with MV [kafka]

2024-06-17 Thread via GitHub
showuon merged PR #16366: URL: https://github.com/apache/kafka/pull/16366 -- 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.

Re: [PR] KAFKA-16969: Log error if config conficts with MV [kafka]

2024-06-17 Thread via GitHub
showuon commented on PR #16366: URL: https://github.com/apache/kafka/pull/16366#issuecomment-2174879458 Failed tests are unrelated. -- 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 co

Re: [PR] improve log description of QuorumController [kafka]

2024-06-17 Thread via GitHub
chickenchickenlove commented on PR #15926: URL: https://github.com/apache/kafka/pull/15926#issuecomment-2174863122 Hey, mumrah. Thanks for your time 🙇‍♂️ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abov

[jira] [Created] (KAFKA-16988) InsufficientResourcesError in ConnectDistributedTest system test

2024-06-17 Thread Luke Chen (Jira)
Luke Chen created KAFKA-16988: - Summary: InsufficientResourcesError in ConnectDistributedTest system test Key: KAFKA-16988 URL: https://issues.apache.org/jira/browse/KAFKA-16988 Project: Kafka I

Re: [PR] KAFKA-16969: revert KAFKA-16606 [kafka]

2024-06-17 Thread via GitHub
showuon closed pull request #16352: KAFKA-16969: revert KAFKA-16606 URL: https://github.com/apache/kafka/pull/16352 -- 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 unsubscri

Re: [PR] KAFKA-16969: revert KAFKA-16606 [kafka]

2024-06-17 Thread via GitHub
showuon commented on PR #16352: URL: https://github.com/apache/kafka/pull/16352#issuecomment-2174853262 Closed in favor of https://github.com/apache/kafka/pull/16366. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use th

[jira] [Assigned] (KAFKA-16956) Broker-side ability to subscribe to record delete events

2024-06-17 Thread dujian0068 (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dujian0068 reassigned KAFKA-16956: -- Assignee: dujian0068 > Broker-side ability to subscribe to record delete events > ---

Re: [PR] KAFKA-16954: fix consumer close to release assignment in background [kafka]

2024-06-17 Thread via GitHub
lianetm commented on PR #16376: URL: https://github.com/apache/kafka/pull/16376#issuecomment-2174790856 Build completed with 4 unrelated failures: > Build / JDK 8 and Scala 2.12 / testSyncTopicConfigs() – org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationExactlyOn

[PR] KAFKA-10787: Apply spotless to `streams:examples` and `streams-scala` [kafka]

2024-06-17 Thread via GitHub
gongxuanzhang opened a new pull request, #16378: URL: https://github.com/apache/kafka/pull/16378 This PR is sub PR from https://github.com/apache/kafka/pull/16097. It is part of a series of changes to progressively apply [spotless plugin(import-order)] across all modules. In this step, th

Re: [PR] KAFKA-16921: Migrate test of connect module to Junit5 (Runtime direct) [kafka]

2024-06-17 Thread via GitHub
gongxuanzhang commented on PR #16351: URL: https://github.com/apache/kafka/pull/16351#issuecomment-2174753090 I update it. plz take a look @chia7712 -- 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

[jira] [Commented] (KAFKA-16986) After upgrading to Kafka 3.4.1, the producer constantly produces logs related to topicId changes

2024-06-17 Thread Vinicius Vieira dos Santos (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17855773#comment-17855773 ] Vinicius Vieira dos Santos commented on KAFKA-16986: [~jolshan] The

Re: [PR] KAFKA-16921: Migrate test of Stream module to Junit5 (Stream state) [kafka]

2024-06-17 Thread via GitHub
m1a2st commented on code in PR #16356: URL: https://github.com/apache/kafka/pull/16356#discussion_r1643586369 ## streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBVersionedStoreSegmentValueFormatterTest.java: ## @@ -18,61 +18,49 @@ import static org.hamcre

Re: [PR] KAFKA-10551: Add topic id support to produce request and response [kafka]

2024-06-17 Thread via GitHub
jolshan commented on code in PR #15968: URL: https://github.com/apache/kafka/pull/15968#discussion_r1643573869 ## core/src/test/scala/unit/kafka/coordinator/group/GroupCoordinatorTest.scala: ## @@ -92,6 +92,7 @@ class GroupCoordinatorTest { private val protocolSuperset = List

Re: [PR] KAFKA-10551: Add topic id support to produce request and response [kafka]

2024-06-17 Thread via GitHub
jolshan commented on code in PR #15968: URL: https://github.com/apache/kafka/pull/15968#discussion_r1643571081 ## core/src/main/scala/kafka/server/KafkaApis.scala: ## @@ -608,40 +608,55 @@ class KafkaApis(val requestChannel: RequestChannel, } } -val unauthorize

Re: [PR] KAFKA-16772: Introduce kraft.version to support KIP-853 [kafka]

2024-06-17 Thread via GitHub
cmccabe commented on PR #16230: URL: https://github.com/apache/kafka/pull/16230#issuecomment-2174664455 I was originally going to have two records: one `KRaftVersionRecord` for the raft layer, and one `FeatureRecord` for the metadata layer, encoding the same data. The advantage of doing it

Re: [PR] KAFKA-10551: Add topic id support to produce request and response [kafka]

2024-06-17 Thread via GitHub
jolshan commented on code in PR #15968: URL: https://github.com/apache/kafka/pull/15968#discussion_r1643566934 ## clients/src/test/java/org/apache/kafka/common/requests/ProduceRequestTest.java: ## @@ -120,15 +121,38 @@ public void testBuildWithCurrentMessageFormat() { P

Re: [PR] KAFKA-10551: Add topic id support to produce request and response [kafka]

2024-06-17 Thread via GitHub
jolshan commented on code in PR #15968: URL: https://github.com/apache/kafka/pull/15968#discussion_r1643566042 ## clients/src/test/java/org/apache/kafka/common/requests/ProduceRequestTest.java: ## @@ -120,15 +121,38 @@ public void testBuildWithCurrentMessageFormat() { P

Re: [PR] KAFKA-10551: Add topic id support to produce request and response [kafka]

2024-06-17 Thread via GitHub
jolshan commented on code in PR #15968: URL: https://github.com/apache/kafka/pull/15968#discussion_r1643566042 ## clients/src/test/java/org/apache/kafka/common/requests/ProduceRequestTest.java: ## @@ -120,15 +121,38 @@ public void testBuildWithCurrentMessageFormat() { P

Re: [PR] KAFKA-10551: Add topic id support to produce request and response [kafka]

2024-06-17 Thread via GitHub
jolshan commented on code in PR #15968: URL: https://github.com/apache/kafka/pull/15968#discussion_r1643562963 ## clients/src/main/java/org/apache/kafka/common/requests/ProduceRequest.java: ## @@ -126,15 +134,15 @@ public ProduceRequest(ProduceRequestData produceRequestData, sh

Re: [PR] KAFKA-16968: Make 3.8-IV0 a stable MetadataVersion and create 3.9-IV0 [kafka]

2024-06-17 Thread via GitHub
junrao commented on PR #16347: URL: https://github.com/apache/kafka/pull/16347#issuecomment-2174646474 @cmccabe : https://github.com/apache/kafka/pull/15673 is fixing a mistake that shouldn't be in 3.8.0. We should have bumped up the API version for ListOffset, but we didn't. To me, that se

Re: [PR] KAFKA-10551: Add topic id support to produce request and response [kafka]

2024-06-17 Thread via GitHub
jolshan commented on code in PR #15968: URL: https://github.com/apache/kafka/pull/15968#discussion_r1643560948 ## clients/src/main/java/org/apache/kafka/common/requests/ProduceRequest.java: ## @@ -51,13 +52,20 @@ public static Builder forMagic(byte magic, ProduceRequestData dat

Re: [PR] KAFKA-10551: Add topic id support to produce request and response [kafka]

2024-06-17 Thread via GitHub
jolshan commented on code in PR #15968: URL: https://github.com/apache/kafka/pull/15968#discussion_r1643560273 ## clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java: ## @@ -891,11 +900,20 @@ private void sendProduceRequest(long now, int destination, s

Re: [PR] MINOR: Don't swallow validateReconfiguration exceptions [kafka]

2024-06-17 Thread via GitHub
cmccabe commented on code in PR #16346: URL: https://github.com/apache/kafka/pull/16346#discussion_r1643559385 ## core/src/main/scala/kafka/server/DynamicBrokerConfig.scala: ## @@ -640,8 +640,8 @@ class DynamicBrokerConfig(private val kafkaConfig: KafkaConfig) extends Logging

Re: [PR] MINOR: add a note in v3.8.0 notable change for JBOD support for tiered storage [kafka]

2024-06-17 Thread via GitHub
satishd commented on PR #16369: URL: https://github.com/apache/kafka/pull/16369#issuecomment-2174632152 @jlprat @showuon Merged to trunk and 3.8 branches. -- 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 t

Re: [PR] MINOR: add a note in v3.8.0 notable change for JBOD support for tiered storage [kafka]

2024-06-17 Thread via GitHub
satishd merged PR #16369: URL: https://github.com/apache/kafka/pull/16369 -- 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-16986) After upgrading to Kafka 3.4.1, the producer constantly produces logs related to topicId changes

2024-06-17 Thread Justine Olshan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17855758#comment-17855758 ] Justine Olshan commented on KAFKA-16986: Hmmm. So the earlier code block should

[jira] [Comment Edited] (KAFKA-16986) After upgrading to Kafka 3.4.1, the producer constantly produces logs related to topicId changes

2024-06-17 Thread Justine Olshan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17855758#comment-17855758 ] Justine Olshan edited comment on KAFKA-16986 at 6/17/24 11:37 PM:

Re: [PR] KAFKA-16977: Reapply dynamic remote configs after broker restart [kafka]

2024-06-17 Thread via GitHub
satishd commented on PR #16353: URL: https://github.com/apache/kafka/pull/16353#issuecomment-2174601994 Retriggered the CI job as one of the test runs timedout. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL a

Re: [PR] MINOR: Don't swallow validateReconfiguration exceptions [kafka]

2024-06-17 Thread via GitHub
ahuang98 commented on code in PR #16346: URL: https://github.com/apache/kafka/pull/16346#discussion_r1643521884 ## core/src/main/scala/kafka/server/DynamicBrokerConfig.scala: ## @@ -640,8 +640,8 @@ class DynamicBrokerConfig(private val kafkaConfig: KafkaConfig) extends Logging

[PR] KAFKA-16749: Implemented share fetch messages (KIP-932) [kafka]

2024-06-17 Thread via GitHub
apoorvmittal10 opened a new pull request, #16377: URL: https://github.com/apache/kafka/pull/16377 Share group consumers use the ShareFetch API to retrieve messages they've claimed (acquired records) from the leader brokers of share partitions. The replica manager provides an API to re

Re: [PR] MINOR: Don't swallow validateReconfiguration exceptions [kafka]

2024-06-17 Thread via GitHub
ahuang98 commented on code in PR #16346: URL: https://github.com/apache/kafka/pull/16346#discussion_r1643505085 ## core/src/main/scala/kafka/server/DynamicBrokerConfig.scala: ## @@ -640,8 +640,8 @@ class DynamicBrokerConfig(private val kafkaConfig: KafkaConfig) extends Logging

Re: [PR] MINOR: Don't swallow validateReconfiguration exceptions [kafka]

2024-06-17 Thread via GitHub
ahuang98 commented on code in PR #16346: URL: https://github.com/apache/kafka/pull/16346#discussion_r1643505085 ## core/src/main/scala/kafka/server/DynamicBrokerConfig.scala: ## @@ -640,8 +640,8 @@ class DynamicBrokerConfig(private val kafkaConfig: KafkaConfig) extends Logging

Re: [PR] KAFKA-16707: Kafka Kraft : using Principal Type in StandardACL in order to defined ACL with a notion of group without rewriting KafkaPrincipal of client by rules [kafka]

2024-06-17 Thread via GitHub
handfreezer commented on PR #16361: URL: https://github.com/apache/kafka/pull/16361#issuecomment-2174527709 Hello, When I'm running "./gradlew test" on my side from apache/kafka/trunk clone, I have failed tests. So Is there a way to know (an easy one?) to know which failed test in "conti

[jira] [Resolved] (KAFKA-12652) connector doesnt accept transformation configuration

2024-06-17 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-12652. - Resolution: Duplicate > connector doesnt accept transformation configuration > -

[jira] [Resolved] (KAFKA-10568) transforms.InsertField.type

2024-06-17 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-10568. - Resolution: Duplicate > transforms.InsertField.type > --- > >

Re: [PR] KAFKA-16862: Refactor ConsumerTaskTest to be deterministic and avoid tight loops [kafka]

2024-06-17 Thread via GitHub
xiaoqingwanga commented on PR #16303: URL: https://github.com/apache/kafka/pull/16303#issuecomment-2174489650 Hey, @gharris1727 , The code has been committed, please review it again. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Gi

Re: [PR] KAFKA-16968: Make 3.8-IV0 a stable MetadataVersion and create 3.9-IV0 [kafka]

2024-06-17 Thread via GitHub
cmccabe commented on code in PR #16347: URL: https://github.com/apache/kafka/pull/16347#discussion_r1643463801 ## server-common/src/main/java/org/apache/kafka/server/common/MetadataVersion.java: ## @@ -202,11 +202,12 @@ public enum MetadataVersion { // Add new fetch request

Re: [PR] KAFKA-16899 GroupRebalanceConfig: rebalanceTimeoutMs updated to commitTimeoutDuringReconciliation [kafka]

2024-06-17 Thread via GitHub
kirktrue commented on PR #16334: URL: https://github.com/apache/kafka/pull/16334#issuecomment-2174472337 My apologies, @linu-shibu. I think the consensus was to change [`MembershipManagerImpl`'s](https://github.com/apache/kafka/blob/trunk/clients/src/main/java/org/apache/kafka/clients

Re: [PR] KAFKA-16862: Refactor ConsumerTaskTest to be deterministic and avoid tight loops [kafka]

2024-06-17 Thread via GitHub
xiaoqingwanga commented on code in PR #16303: URL: https://github.com/apache/kafka/pull/16303#discussion_r1643456559 ## storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/ConsumerTaskTest.java: ## @@ -309,49 +300,52 @@ public void testCanReprocessSkippedRe

Re: [PR] MINOR: consumer log fixes [kafka]

2024-06-17 Thread via GitHub
kirktrue commented on code in PR #16345: URL: https://github.com/apache/kafka/pull/16345#discussion_r1643453935 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java: ## @@ -785,6 +805,13 @@ void removeRequest() { } } +

Re: [PR] MINOR: consumer log fixes [kafka]

2024-06-17 Thread via GitHub
kirktrue commented on code in PR #16345: URL: https://github.com/apache/kafka/pull/16345#discussion_r1643453077 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java: ## @@ -362,7 +362,7 @@ private void transitionTo(MemberState nextState

[jira] [Updated] (KAFKA-16942) Use ConcurrentHashMap in RecordAccumulator#nodeStats

2024-06-17 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16942: -- Component/s: producer > Use ConcurrentHashMap in RecordAccumulator#nodeStats > --

[jira] [Comment Edited] (KAFKA-16986) After upgrading to Kafka 3.4.1, the producer constantly produces logs related to topicId changes

2024-06-17 Thread Vinicius Vieira dos Santos (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17855730#comment-17855730 ] Vinicius Vieira dos Santos edited comment on KAFKA-16986 at 6/17/24 9:26 PM: -

Re: [PR] MINOR: consumer log fixes [kafka]

2024-06-17 Thread via GitHub
lianetm commented on code in PR #16345: URL: https://github.com/apache/kafka/pull/16345#discussion_r1643448438 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java: ## @@ -362,7 +362,7 @@ private void transitionTo(MemberState nextState)

Re: [PR] MINOR: consumer log fixes [kafka]

2024-06-17 Thread via GitHub
lianetm commented on code in PR #16345: URL: https://github.com/apache/kafka/pull/16345#discussion_r1643442351 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java: ## @@ -785,6 +805,13 @@ void removeRequest() { } } +

Re: [PR] KAFKA-16968: Make 3.8-IV0 a stable MetadataVersion and create 3.9-IV0 [kafka]

2024-06-17 Thread via GitHub
cmccabe commented on code in PR #16347: URL: https://github.com/apache/kafka/pull/16347#discussion_r1643441501 ## server-common/src/main/java/org/apache/kafka/server/common/GroupVersion.java: ## @@ -22,7 +22,7 @@ public enum GroupVersion implements FeatureVersion { // Ve

[jira] [Updated] (KAFKA-16957) Enable KafkaConsumerTest#configurableObjectsShouldSeeGeneratedClientId to work with CLASSIC and CONSUMER

2024-06-17 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16957: -- Fix Version/s: 3.9.0 > Enable KafkaConsumerTest#configurableObjectsShouldSeeGeneratedClientId to > wo

[jira] [Updated] (KAFKA-16957) Enable KafkaConsumerTest#configurableObjectsShouldSeeGeneratedClientId to work with CLASSIC and CONSUMER

2024-06-17 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16957: -- Component/s: clients consumer unit tests > Enable KafkaConsumerTest#

Re: [PR] KAFKA-16968: Make 3.8-IV0 a stable MetadataVersion and create 3.9-IV0 [kafka]

2024-06-17 Thread via GitHub
cmccabe commented on PR #16347: URL: https://github.com/apache/kafka/pull/16347#issuecomment-2174438309 > @cmccabe @AndrewJSchofield @dajac , there is another PR adding a new metadata version of 3.8.IV1(it will be the next production ready MV), it also tries to move KIP-966 from 3.8IV0 to 4

Re: [PR] 3.8 cherry-pick for KAFKA-16954 [kafka]

2024-06-17 Thread via GitHub
lianetm commented on PR #16376: URL: https://github.com/apache/kafka/pull/16376#issuecomment-2174438045 Hey @lucasbru , here is the PR cherry-picking only the required changes for 3.8 for the consumer close fix. The conflicts were due to this client cleanup commit https://github.com/apache

Re: [PR] KAFKA-16480: Bump ListOffsets version, IBP version and mark last version of ListOffsets as unstable [kafka]

2024-06-17 Thread via GitHub
cmccabe commented on PR #15673: URL: https://github.com/apache/kafka/pull/15673#issuecomment-2174437063 3.8 is done at this point. These changes can be done in 3.9-IV0 once #16347 is in. -- This is an automated message from the Apache Git Service. To respond to the message, please log on

Re: [PR] KAFKA-16968: Make 3.8-IV0 a stable MetadataVersion and create 3.9-IV0 [kafka]

2024-06-17 Thread via GitHub
cmccabe commented on code in PR #16347: URL: https://github.com/apache/kafka/pull/16347#discussion_r1643436916 ## server-common/src/main/java/org/apache/kafka/server/common/MetadataVersion.java: ## @@ -232,7 +233,7 @@ public enum MetadataVersion { * Think carefully before

[jira] [Updated] (KAFKA-16986) After upgrading to Kafka 3.4.1, the producer constantly produces logs related to topicId changes

2024-06-17 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16986: -- Component/s: producer > After upgrading to Kafka 3.4.1, the producer constantly produces logs related

[PR] 3.8 cherry-pick for KAFKA-16954 [kafka]

2024-06-17 Thread via GitHub
lianetm opened a new pull request, #16376: URL: https://github.com/apache/kafka/pull/16376 Cherry-picking 2 commits required for fixing KAFKA-16954 for 3.8 (fix consumer close to release assignment in background) -- This is an automated message from the Apache Git Service. To respond

Re: [PR] KAFKA-16788 - Fix resource leakage during connector start() failure [kafka]

2024-06-17 Thread via GitHub
gharris1727 commented on code in PR #16095: URL: https://github.com/apache/kafka/pull/16095#discussion_r1643426226 ## connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConnector.java: ## @@ -231,6 +231,12 @@ private synchronized void onFailure(Throwable t) {

[jira] [Created] (KAFKA-16987) Release connector & task resources when entering FAILED state

2024-06-17 Thread Greg Harris (Jira)
Greg Harris created KAFKA-16987: --- Summary: Release connector & task resources when entering FAILED state Key: KAFKA-16987 URL: https://issues.apache.org/jira/browse/KAFKA-16987 Project: Kafka

Re: [PR] MINOR: consumer log fixes [kafka]

2024-06-17 Thread via GitHub
kirktrue commented on code in PR #16345: URL: https://github.com/apache/kafka/pull/16345#discussion_r1643412421 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java: ## @@ -785,6 +805,13 @@ void removeRequest() { } } +

[jira] [Resolved] (KAFKA-10670) repo.maven.apache.org: Name or service not known

2024-06-17 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-10670. - Resolution: Cannot Reproduce > repo.maven.apache.org: Name or service not known > --

[jira] [Commented] (KAFKA-16986) After upgrading to Kafka 3.4.1, the producer constantly produces logs related to topicId changes

2024-06-17 Thread Vinicius Vieira dos Santos (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17855730#comment-17855730 ] Vinicius Vieira dos Santos commented on KAFKA-16986: [~jolshan] In t

[jira] [Commented] (KAFKA-16986) After upgrading to Kafka 3.4.1, the producer constantly produces logs related to topicId changes

2024-06-17 Thread Justine Olshan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17855729#comment-17855729 ] Justine Olshan commented on KAFKA-16986: Hey there, this has been fixed for vers

[jira] [Resolved] (KAFKA-5736) Improve error message in Connect when all kafka brokers are down

2024-06-17 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-5736. Assignee: (was: Konstantine Karantasis) Resolution: Won't Fix This appears to be a third-

[jira] [Updated] (KAFKA-16986) After upgrading to Kafka 3.4.1, the producer constantly produces logs related to topicId changes

2024-06-17 Thread Vinicius Vieira dos Santos (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vinicius Vieira dos Santos updated KAFKA-16986: --- Summary: After upgrading to Kafka 3.4.1, the producer constantly prod

[jira] [Updated] (KAFKA-16986) After upgrading to Kafka 3.41, the producer constantly produces logs related to topicId changes

2024-06-17 Thread Vinicius Vieira dos Santos (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vinicius Vieira dos Santos updated KAFKA-16986: --- Description: When updating the Kafka broker from version 2.7.0 to 3.

[jira] [Updated] (KAFKA-16986) After upgrading to Kafka 3.41, the producer constantly produces logs related to topicId changes

2024-06-17 Thread Vinicius Vieira dos Santos (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vinicius Vieira dos Santos updated KAFKA-16986: --- Description: When updating the Kafka broker from version 2.7.0 to 3.

[jira] [Updated] (KAFKA-16986) After upgrading to Kafka 3.41, the producer constantly produces logs related to topicId changes

2024-06-17 Thread Vinicius Vieira dos Santos (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vinicius Vieira dos Santos updated KAFKA-16986: --- Priority: Minor (was: Major) > After upgrading to Kafka 3.41, the p

[jira] [Updated] (KAFKA-16986) After upgrading to Kafka 3.41, the producer constantly produces logs related to topicId changes

2024-06-17 Thread Vinicius Vieira dos Santos (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vinicius Vieira dos Santos updated KAFKA-16986: --- Description: When updating the Kafka broker from version 2.7.0 to 3.

[jira] [Resolved] (KAFKA-12164) ssue when kafka connect worker pod restart, during creation of nested partition directories in hdfs file system.

2024-06-17 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-12164. - Resolution: Invalid This issue appears to deal only with a Connect plugin, which is not supporte

[jira] [Updated] (KAFKA-16986) After upgrading to Kafka 3.41, the producer constantly produces logs related to topicId changes

2024-06-17 Thread Vinicius Vieira dos Santos (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vinicius Vieira dos Santos updated KAFKA-16986: --- Description: When updating the Kafka broker from version 2.7.0 to 3.

[jira] [Updated] (KAFKA-16986) After upgrading to Kafka 3.41, the producer constantly produces logs related to topicId changes

2024-06-17 Thread Vinicius Vieira dos Santos (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vinicius Vieira dos Santos updated KAFKA-16986: --- Attachment: image.png > After upgrading to Kafka 3.41, the producer

[jira] [Resolved] (KAFKA-6353) Connector status shows FAILED but actually task is in RUNNING status

2024-06-17 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-6353. Resolution: Not A Bug The REST API provides separate status for a connector and it's tasks. Any one

[jira] [Updated] (KAFKA-16986) After upgrading to Kafka 3.41, the producer constantly produces logs related to topicId changes

2024-06-17 Thread Vinicius Vieira dos Santos (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vinicius Vieira dos Santos updated KAFKA-16986: --- Description: When updating the Kafka broker from version 2.7.0 to 3.

[jira] [Updated] (KAFKA-16986) After upgrading to Kafka 3.41, the producer constantly produces logs related to topicId changes

2024-06-17 Thread Vinicius Vieira dos Santos (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vinicius Vieira dos Santos updated KAFKA-16986: --- Description: When updating the Kafka broker from version 2.7.0 to 3.

[jira] [Created] (KAFKA-16986) After upgrading to Kafka 3.41, the producer constantly produces logs related to topicId changes

2024-06-17 Thread Vinicius Vieira dos Santos (Jira)
Vinicius Vieira dos Santos created KAFKA-16986: -- Summary: After upgrading to Kafka 3.41, the producer constantly produces logs related to topicId changes Key: KAFKA-16986 URL: https://issues.apache.or

Re: [PR] KAFKA-16936 : Upgrade slf4j, sys property for provider [kafka]

2024-06-17 Thread via GitHub
gharris1727 commented on code in PR #16324: URL: https://github.com/apache/kafka/pull/16324#discussion_r1643357210 ## bin/kafka-run-class.sh: ## @@ -243,6 +243,14 @@ fi (( WINDOWS_OS_FORMAT )) && LOG_DIR=$(cygpath --path --mixed "${LOG_DIR}") KAFKA_LOG4J_CMD_OPTS="-Dkafka.logs

  1   2   3   4   >