[GitHub] [kafka] dajac merged pull request #11988: MINOR: fix typo in FetchRequest.json

2022-04-04 Thread GitBox
dajac merged PR #11988: URL: https://github.com/apache/kafka/pull/11988 -- 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.or

[GitHub] [kafka] dajac merged pull request #11987: MINOR: Fix flaky testClientDisconnectionUpdatesRequestMetrics()

2022-04-04 Thread GitBox
dajac merged PR #11987: URL: https://github.com/apache/kafka/pull/11987 -- 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.or

[GitHub] [kafka] bozhao12 commented on a diff in pull request #11965: KAFKA-13778: Fetch from follower should never run the preferred read replica selection

2022-04-04 Thread GitBox
bozhao12 commented on code in PR #11965: URL: https://github.com/apache/kafka/pull/11965#discussion_r841507306 ## core/src/main/scala/kafka/server/ReplicaManager.scala: ## @@ -1234,8 +1234,9 @@ class ReplicaManager(val config: KafkaConfig, fetchOf

[GitHub] [kafka] bozhao12 commented on a diff in pull request #11965: KAFKA-13778: Fetch from follower should never run the preferred read replica selection

2022-04-04 Thread GitBox
bozhao12 commented on code in PR #11965: URL: https://github.com/apache/kafka/pull/11965#discussion_r841507306 ## core/src/main/scala/kafka/server/ReplicaManager.scala: ## @@ -1234,8 +1234,9 @@ class ReplicaManager(val config: KafkaConfig, fetchOf

[GitHub] [kafka] bozhao12 commented on a diff in pull request #11965: KAFKA-13778: Fetch from follower should never run the preferred read replica selection

2022-04-04 Thread GitBox
bozhao12 commented on code in PR #11965: URL: https://github.com/apache/kafka/pull/11965#discussion_r841509645 ## core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala: ## @@ -3719,3 +3767,19 @@ class ReplicaManagerTest { } } } + +class MockReplicaSelector exte

[jira] [Created] (KAFKA-13795) MM2 Default topics.exclude does not work

2022-04-04 Thread David Bros (Jira)
David Bros created KAFKA-13795: -- Summary: MM2 Default topics.exclude does not work Key: KAFKA-13795 URL: https://issues.apache.org/jira/browse/KAFKA-13795 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-13795) MM2 Default topics.exclude does not work

2022-04-04 Thread David Bros (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Bros resolved KAFKA-13795. Resolution: Abandoned > MM2 Default topics.exclude does not work > --

[GitHub] [kafka] mimaison commented on pull request #11906: MINOR: Doc updates for Kafka 3.0.1

2022-04-04 Thread GitBox
mimaison commented on PR #11906: URL: https://github.com/apache/kafka/pull/11906#issuecomment-1087376812 ping @dajac -- 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 uns

[GitHub] [kafka] mimaison commented on pull request #11975: MINOR: Improve the log output information of SocketServer

2022-04-04 Thread GitBox
mimaison commented on PR #11975: URL: https://github.com/apache/kafka/pull/11975#issuecomment-1087382412 I too prefer `endpoint` over `listenerName`. `listenerName` is really an internal concept, while endpoint is commonly used. -- This is an automated message from the Apache Git Service.

[jira] [Created] (KAFKA-13796) MM2 - Topics Exclude/Blacklist not working

2022-04-04 Thread David Bros (Jira)
David Bros created KAFKA-13796: -- Summary: MM2 - Topics Exclude/Blacklist not working Key: KAFKA-13796 URL: https://issues.apache.org/jira/browse/KAFKA-13796 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-13796) MM2 - Topics Exclude/Blacklist not working

2022-04-04 Thread David Bros (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Bros updated KAFKA-13796: --- Description: Hi all, We are testing Kafka 3.0.0 in a development environment with Java 17 in a Cen

[GitHub] [kafka] sciclon2 commented on pull request #11842: KAFKA-13687: Limiting the amount of bytes to be read in a segment logs

2022-04-04 Thread GitBox
sciclon2 commented on PR #11842: URL: https://github.com/apache/kafka/pull/11842#issuecomment-1087390274 @junrao , The KIP was voted and adopted, I checked the KIP documentation I don't know what are the next steps, should I do anything else ? thanks! -- This is an automated messag

[GitHub] [kafka] dajac commented on a diff in pull request #11965: KAFKA-13778: Fetch from follower should never run the preferred read replica selection

2022-04-04 Thread GitBox
dajac commented on code in PR #11965: URL: https://github.com/apache/kafka/pull/11965#discussion_r841628203 ## core/src/main/scala/kafka/server/ReplicaManager.scala: ## @@ -1234,8 +1234,9 @@ class ReplicaManager(val config: KafkaConfig, fetchOffse

[jira] [Commented] (KAFKA-13796) MM2 - Topics Exclude/Blacklist not working

2022-04-04 Thread David Bros (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516755#comment-17516755 ] David Bros commented on KAFKA-13796: We solved the issue for now by not matching in

[jira] [Commented] (KAFKA-13783) Remove reason prefixing in JoinGroupRequest and LeaveGroupRequest

2022-04-04 Thread David Jacot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516757#comment-17516757 ] David Jacot commented on KAFKA-13783: - [~tombentley] Done. I have updated the KIP an

[jira] [Comment Edited] (KAFKA-13796) MM2 - Topics Exclude/Blacklist not working

2022-04-04 Thread David Bros (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516755#comment-17516755 ] David Bros edited comment on KAFKA-13796 at 4/4/22 11:47 AM: -

[jira] [Comment Edited] (KAFKA-13796) MM2 - Topics Exclude/Blacklist not working

2022-04-04 Thread David Bros (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516755#comment-17516755 ] David Bros edited comment on KAFKA-13796 at 4/4/22 11:47 AM: -

[jira] [Comment Edited] (KAFKA-13796) MM2 - Topics Exclude/Blacklist not working

2022-04-04 Thread David Bros (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516755#comment-17516755 ] David Bros edited comment on KAFKA-13796 at 4/4/22 11:48 AM: -

[jira] [Comment Edited] (KAFKA-13796) MM2 - Topics Exclude/Blacklist not working

2022-04-04 Thread David Bros (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516755#comment-17516755 ] David Bros edited comment on KAFKA-13796 at 4/4/22 11:49 AM: -

[GitHub] [kafka] dengziming commented on pull request #11990: KAFKA-13792: Fix wrong package name in Scala test files

2022-04-04 Thread GitBox
dengziming commented on PR #11990: URL: https://github.com/apache/kafka/pull/11990#issuecomment-1087463025 > what’s the advantage set to this because we have integration test and unit test, you can find that we have 2 subdirs in the `test` dir. -- This is an automated message from

[GitHub] [kafka] Nayana-ibm commented on pull request #11929: MINOR: s390x Stage

2022-04-04 Thread GitBox
Nayana-ibm commented on PR #11929: URL: https://github.com/apache/kafka/pull/11929#issuecomment-1087467404 @mimaison Any update on approval? When this PR will get merged? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [kafka] bozhao12 commented on a diff in pull request #11965: KAFKA-13778: Fetch from follower should never run the preferred read replica selection

2022-04-04 Thread GitBox
bozhao12 commented on code in PR #11965: URL: https://github.com/apache/kafka/pull/11965#discussion_r841660183 ## core/src/main/scala/kafka/server/ReplicaManager.scala: ## @@ -1234,8 +1234,9 @@ class ReplicaManager(val config: KafkaConfig, fetchOf

[jira] [Commented] (KAFKA-13783) Remove reason prefixing in JoinGroupRequest and LeaveGroupRequest

2022-04-04 Thread Tom Bentley (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516775#comment-17516775 ] Tom Bentley commented on KAFKA-13783: - Thanks! > Remove reason prefixing in JoinGro

[GitHub] [kafka] mimaison commented on pull request #11929: MINOR: s390x Stage

2022-04-04 Thread GitBox
mimaison commented on PR #11929: URL: https://github.com/apache/kafka/pull/11929#issuecomment-1087505632 @Nayana-ibm I started a discussion on the mailing list, see https://lists.apache.org/thread/mfcc5pcky8xh0lfr173m0lm4fgvc6td1 -- This is an automated message from the Apache Git Service

[GitHub] [kafka] mimaison merged pull request #11906: MINOR: Doc updates for Kafka 3.0.1

2022-04-04 Thread GitBox
mimaison merged PR #11906: URL: https://github.com/apache/kafka/pull/11906 -- 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-13272) KStream offset stuck after brokers outage

2022-04-04 Thread Levani Kokhreidze (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516798#comment-17516798 ] Levani Kokhreidze commented on KAFKA-13272: --- Hi [~guozhang] , [~ableegoldman] 

[GitHub] [kafka] YeonCheolGit commented on pull request #11990: KAFKA-13792: Fix wrong package name in Scala test files

2022-04-04 Thread GitBox
YeonCheolGit commented on PR #11990: URL: https://github.com/apache/kafka/pull/11990#issuecomment-1087526769 > > what’s the advantage > > set to this because we have integration test and unit test, you can find that we have 2 subdirs in the `test` dir. Thanks for letting me kno

[jira] [Commented] (KAFKA-13793) Add validators for serialization and deserialization related configuration

2022-04-04 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516823#comment-17516823 ] RivenSun commented on KAFKA-13793: -- Hi [~guozhang]  [~dajac] , [~showuon] Could you giv

[GitHub] [kafka] RivenSun2 commented on pull request #11975: MINOR: Improve the log output information of SocketServer

2022-04-04 Thread GitBox
RivenSun2 commented on PR #11975: URL: https://github.com/apache/kafka/pull/11975#issuecomment-1087581308 Hi @showuon @mimaison Thanks for your review. let me close this PR. Thanks. -- This is an automated message from the Apache Git Service. To respond to the message, pleas

[GitHub] [kafka] RivenSun2 closed pull request #11975: MINOR: Improve the log output information of SocketServer

2022-04-04 Thread GitBox
RivenSun2 closed pull request #11975: MINOR: Improve the log output information of SocketServer URL: https://github.com/apache/kafka/pull/11975 -- 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 sp

[GitHub] [kafka] RivenSun2 commented on pull request #11992: MINOR: Fix wrong configuration of `inter.broker.security.protocol` for communication between brokers

2022-04-04 Thread GitBox
RivenSun2 commented on PR #11992: URL: https://github.com/apache/kafka/pull/11992#issuecomment-1087583883 Hi @showuon @dajac and @mimaison could you help to review the PR? Thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on t

[GitHub] [kafka] RivenSun2 commented on pull request #11985: MINOR: Supplement the description of `Valid Values` in the documentation of `compression.type`

2022-04-04 Thread GitBox
RivenSun2 commented on PR #11985: URL: https://github.com/apache/kafka/pull/11985#issuecomment-1087584508 Hi @showuon @dajac and @mimaison could you help to review the PR? Thanks a lot. -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [kafka] RivenSun2 commented on pull request #11947: MINOR: Improve the description of principal under different mechanisms of sasl

2022-04-04 Thread GitBox
RivenSun2 commented on PR #11947: URL: https://github.com/apache/kafka/pull/11947#issuecomment-1087585550 Hi @showuon @dajac and @mimaison could you help to review the PR? Thanks a lot. -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [kafka] RivenSun2 commented on pull request #11976: KAFKA-13771: Support to explicitly delete delegationTokens that have expired but have not been automatically cleaned up

2022-04-04 Thread GitBox
RivenSun2 commented on PR #11976: URL: https://github.com/apache/kafka/pull/11976#issuecomment-1087593035 Hi @showuon @dajac and @mimaison could you help to review the PR? Thanks a lot. -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [kafka] tombentley commented on pull request #11994: MINOR: Mention KAFKA-13748 in release notes

2022-04-04 Thread GitBox
tombentley commented on PR #11994: URL: https://github.com/apache/kafka/pull/11994#issuecomment-1087649367 @kkonstantine PTAL. -- 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

[GitHub] [kafka] tombentley opened a new pull request, #11994: MINOR: Mention KAFKA-13748 in release notes

2022-04-04 Thread GitBox
tombentley opened a new pull request, #11994: URL: https://github.com/apache/kafka/pull/11994 KAFKA-13748 removed the FileStreamSinkConnector and FileStreamSinkConnector from the default classpath. Although these are provided for example purposes only, it makes sense to mention this in the

[GitHub] [kafka] mimaison commented on pull request #11906: MINOR: Doc updates for Kafka 3.0.1

2022-04-04 Thread GitBox
mimaison commented on PR #11906: URL: https://github.com/apache/kafka/pull/11906#issuecomment-1087684315 I wonder if we should prevent editing files in `kafka-site` altogether and ask users to always do them in `kafka`. -- This is an automated message from the Apache Git Service. To respo

[jira] [Commented] (KAFKA-13684) KStream rebalance can lead to JVM process crash when network issues occure

2022-04-04 Thread Peter Cipov (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516900#comment-17516900 ] Peter Cipov commented on KAFKA-13684: - hello [~guozhang]    We have investigated t

[GitHub] [kafka] mimaison commented on a diff in pull request #11985: MINOR: Supplement the description of `Valid Values` in the documentation of `compression.type`

2022-04-04 Thread GitBox
mimaison commented on code in PR #11985: URL: https://github.com/apache/kafka/pull/11985#discussion_r841863190 ## clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java: ## @@ -329,7 +330,7 @@ in("all", "-1", "0", "1"

[GitHub] [kafka] tombentley commented on pull request #11994: MINOR: Mention KAFKA-13748 in release notes

2022-04-04 Thread GitBox
tombentley commented on PR #11994: URL: https://github.com/apache/kafka/pull/11994#issuecomment-1087701062 @cadonna are you OK for me to cherry-pick this to 3.2? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [kafka] mimaison merged pull request #11992: MINOR: Fix wrong configuration of `inter.broker.security.protocol` for communication between brokers

2022-04-04 Thread GitBox
mimaison merged PR #11992: URL: https://github.com/apache/kafka/pull/11992 -- 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] dajac commented on pull request #11906: MINOR: Doc updates for Kafka 3.0.1

2022-04-04 Thread GitBox
dajac commented on PR #11906: URL: https://github.com/apache/kafka/pull/11906#issuecomment-1087722280 I usually ask them to open two PRs. The issue is that the doc in kafka might be way ahead of the current release (e.g. new features). -- This is an automated message from the Apache Git S

[jira] [Resolved] (KAFKA-13684) KStream rebalance can lead to JVM process crash when network issues occure

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-13684. --- Resolution: Not A Bug > KStream rebalance can lead to JVM process crash when network issues

[jira] [Updated] (KAFKA-13295) Long restoration times for new tasks can lead to transaction timeouts

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-13295: -- Fix Version/s: (was: 3.2.0) > Long restoration times for new tasks can lead to transaction

[jira] [Commented] (KAFKA-13295) Long restoration times for new tasks can lead to transaction timeouts

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516945#comment-17516945 ] Bruno Cadonna commented on KAFKA-13295: --- Removing from 3.2. release since code fre

[jira] [Commented] (KAFKA-13159) Enable system tests for transactions in KRaft mode

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516947#comment-17516947 ] Bruno Cadonna commented on KAFKA-13159: --- [~mumrah] Same question as [~mimaison]: C

[jira] [Updated] (KAFKA-13159) Enable system tests for transactions in KRaft mode

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-13159: -- Fix Version/s: (was: 3.2.0) > Enable system tests for transactions in KRaft mode > ---

[jira] [Comment Edited] (KAFKA-13159) Enable system tests for transactions in KRaft mode

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516947#comment-17516947 ] Bruno Cadonna edited comment on KAFKA-13159 at 4/4/22 4:52 PM: ---

[GitHub] [kafka] mimaison commented on a diff in pull request #11974: KAFKA-13763 (1): Improve unit testing coverage and flexibility for IncrementalCooperativeAssignor

2022-04-04 Thread GitBox
mimaison commented on code in PR #11974: URL: https://github.com/apache/kafka/pull/11974#discussion_r841936725 ## connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignorTest.java: ## @@ -34,25 +34,30 @@ import org.mockito.junit.

[jira] [Resolved] (KAFKA-13159) Enable system tests for transactions in KRaft mode

2022-04-04 Thread David Arthur (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur resolved KAFKA-13159. -- Resolution: Fixed Resolving as these tests have been enabled on trunk for a while now: https:

[jira] [Commented] (KAFKA-7509) Kafka Connect logs unnecessary warnings about unused configurations

2022-04-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516979#comment-17516979 ] Matthias J. Sax commented on KAFKA-7509: Thanks for following up. – I briefly too

[jira] [Updated] (KAFKA-13159) Enable system tests for transactions in KRaft mode

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-13159: -- Fix Version/s: 3.2.0 > Enable system tests for transactions in KRaft mode > --

[jira] [Commented] (KAFKA-13474) Regression in dynamic update of broker certificate

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516984#comment-17516984 ] Bruno Cadonna commented on KAFKA-13474: --- Moving to the next release since code fre

[jira] [Updated] (KAFKA-13474) Regression in dynamic update of broker certificate

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-13474: -- Fix Version/s: 3.3.0 (was: 3.2.0) > Regression in dynamic update of bro

[jira] [Commented] (KAFKA-12291) Fix Ignored Upgrade Tests in streams_upgrade_test.py: test_upgrade_downgrade_brokers

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516987#comment-17516987 ] Bruno Cadonna commented on KAFKA-12291: --- Removing from release 3.2.0 since code fr

[jira] [Updated] (KAFKA-12291) Fix Ignored Upgrade Tests in streams_upgrade_test.py: test_upgrade_downgrade_brokers

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12291: -- Fix Version/s: (was: 3.2.0) > Fix Ignored Upgrade Tests in streams_upgrade_test.py: > tes

[jira] [Commented] (KAFKA-7509) Kafka Connect logs unnecessary warnings about unused configurations

2022-04-04 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516992#comment-17516992 ] Chris Egerton commented on KAFKA-7509: -- [~mjsax] thanks for taking a look. RE {{conn

[GitHub] [kafka] C0urante commented on a diff in pull request #11974: KAFKA-13763 (1): Improve unit testing coverage and flexibility for IncrementalCooperativeAssignor

2022-04-04 Thread GitBox
C0urante commented on code in PR #11974: URL: https://github.com/apache/kafka/pull/11974#discussion_r842022697 ## connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignorTest.java: ## @@ -1275,89 +1136,68 @@ private static Cluster

[jira] [Created] (KAFKA-13797) Adding metric to indicate metadata response outgoing bytes rate

2022-04-04 Thread Lucas Wang (Jira)
Lucas Wang created KAFKA-13797: -- Summary: Adding metric to indicate metadata response outgoing bytes rate Key: KAFKA-13797 URL: https://issues.apache.org/jira/browse/KAFKA-13797 Project: Kafka

[jira] [Updated] (KAFKA-12878) Support --bootstrap-server kafka-streams-application-reset

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12878: -- Component/s: streams > Support --bootstrap-server kafka-streams-application-reset > --

[jira] [Updated] (KAFKA-12878) Support --bootstrap-server kafka-streams-application-reset

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12878: -- Labels: needs-kip (was: ) > Support --bootstrap-server kafka-streams-application-reset >

[jira] [Updated] (KAFKA-12878) Support --bootstrap-server kafka-streams-application-reset

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12878: -- Fix Version/s: (was: 3.2.0) > Support --bootstrap-server kafka-streams-application-reset >

[jira] [Updated] (KAFKA-12878) Support --bootstrap-server kafka-streams-application-reset

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12878: -- Priority: Major (was: Critical) > Support --bootstrap-server kafka-streams-application-reset

[jira] [Updated] (KAFKA-12878) Support --bootstrap-server kafka-streams-application-reset

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12878: -- Labels: needs-kip newbie (was: needs-kip) > Support --bootstrap-server kafka-streams-applicat

[jira] [Commented] (KAFKA-12878) Support --bootstrap-server kafka-streams-application-reset

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516996#comment-17516996 ] Bruno Cadonna commented on KAFKA-12878: --- Removing from 3.2.0 relase since code fre

[jira] [Commented] (KAFKA-13331) Slow reassignments in 2.8 because of large number of UpdateMetadataResponseReceived(UpdateMetadataResponseData(errorCode=0),) Events

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17517022#comment-17517022 ] Bruno Cadonna commented on KAFKA-13331: --- Removing from the 3.2.0 release since cod

[jira] [Updated] (KAFKA-13331) Slow reassignments in 2.8 because of large number of UpdateMetadataResponseReceived(UpdateMetadataResponseData(errorCode=0),) Events

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-13331: -- Fix Version/s: (was: 3.2.0) > Slow reassignments in 2.8 because of large number of > Upd

[jira] [Updated] (KAFKA-13411) Exception while connecting from kafka client consumer producers deployed in a wildfly context to a kafka broker implementing OAUTHBEARER sasl mechanism

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-13411: -- Fix Version/s: (was: 3.2.0) > Exception while connecting from kafka client consumer produc

[jira] [Commented] (KAFKA-13411) Exception while connecting from kafka client consumer producers deployed in a wildfly context to a kafka broker implementing OAUTHBEARER sasl mechanism

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17517024#comment-17517024 ] Bruno Cadonna commented on KAFKA-13411: --- Removing from the 3.2.0 release since cod

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

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17517025#comment-17517025 ] Bruno Cadonna commented on KAFKA-9837: -- Removing from 3.2.0 release since code freez

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

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-9837: - Fix Version/s: (was: 3.2.0) > New RPC for notifying controller of failed replica > --

[jira] [Commented] (KAFKA-12644) Add Missing Class-Level Javadoc to Descendants of org.apache.kafka.common.errors.ApiException

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17517027#comment-17517027 ] Bruno Cadonna commented on KAFKA-12644: --- Removing from the 3.2.0 release since cod

[jira] [Updated] (KAFKA-12644) Add Missing Class-Level Javadoc to Descendants of org.apache.kafka.common.errors.ApiException

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12644: -- Fix Version/s: (was: 3.2.0) > Add Missing Class-Level Javadoc to Descendants of > org.apa

[jira] [Commented] (KAFKA-9550) RemoteLogManager implementation

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17517030#comment-17517030 ] Bruno Cadonna commented on KAFKA-9550: -- Remove from the 3.2.0 release since code fre

[jira] [Updated] (KAFKA-9550) RemoteLogManager implementation

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-9550: - Fix Version/s: (was: 3.2.0) > RemoteLogManager implementation >

[jira] [Updated] (KAFKA-9578) Kafka Tiered Storage - System Tests

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-9578: - Fix Version/s: (was: 3.2.0) > Kafka Tiered Storage - System Tests >

[jira] [Comment Edited] (KAFKA-9550) RemoteLogManager implementation

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17517030#comment-17517030 ] Bruno Cadonna edited comment on KAFKA-9550 at 4/4/22 6:40 PM: -

[jira] [Commented] (KAFKA-9578) Kafka Tiered Storage - System Tests

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17517032#comment-17517032 ] Bruno Cadonna commented on KAFKA-9578: -- Remove from the 3.2.0 release since code fre

[jira] [Updated] (KAFKA-9990) Supporting transactions in tiered storage

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-9990: - Fix Version/s: (was: 3.2.0) > Supporting transactions in tiered storage > ---

[jira] [Comment Edited] (KAFKA-9578) Kafka Tiered Storage - System Tests

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17517032#comment-17517032 ] Bruno Cadonna edited comment on KAFKA-9578 at 4/4/22 6:40 PM: -

[jira] [Assigned] (KAFKA-13668) Failed cluster authorization should not be fatal for producer

2022-04-04 Thread Philip Nee (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Philip Nee reassigned KAFKA-13668: -- Assignee: Philip Nee (was: Kirk True) > Failed cluster authorization should not be fatal for

[jira] [Commented] (KAFKA-9990) Supporting transactions in tiered storage

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17517034#comment-17517034 ] Bruno Cadonna commented on KAFKA-9990: -- Removing from the 3.2.0 release since code f

[GitHub] [kafka] hachikuji opened a new pull request, #11995: KAFKA-13782; Ensure correct partition added to txn after abort on full batch

2022-04-04 Thread GitBox
hachikuji opened a new pull request, #11995: URL: https://github.com/apache/kafka/pull/11995 Fixes a regression introduced in https://github.com/apache/kafka/pull/11452. Following [KIP-480](https://cwiki.apache.org/confluence/display/KAFKA/KIP-480%3A+Sticky+Partitioner), the `Partitioner`

[jira] [Commented] (KAFKA-13782) Producer may fail to add the correct partition to transaction

2022-04-04 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17517085#comment-17517085 ] Jason Gustafson commented on KAFKA-13782: - [~tombentley] Apologies for the delay

[jira] [Updated] (KAFKA-12616) Convert integration tests to use ClusterTest

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12616: -- Fix Version/s: (was: 3.2.0) > Convert integration tests to use ClusterTest >

[jira] [Commented] (KAFKA-12616) Convert integration tests to use ClusterTest

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17517098#comment-17517098 ] Bruno Cadonna commented on KAFKA-12616: --- Removing from the 3.2.0 release since cod

[jira] [Updated] (KAFKA-13560) Load indexes and data in async manner in the critical path of replica fetcher threads.

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-13560: -- Fix Version/s: (was: 3.2.0) > Load indexes and data in async manner in the critical path o

[jira] [Commented] (KAFKA-13560) Load indexes and data in async manner in the critical path of replica fetcher threads.

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17517100#comment-17517100 ] Bruno Cadonna commented on KAFKA-13560: --- Removing from the 3.2.0 release since cod

[jira] [Updated] (KAFKA-7435) Consider standardizing the config object pattern on interface/implementation.

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-7435: - Fix Version/s: (was: 3.2.0) > Consider standardizing the config object pattern on interface/i

[jira] [Commented] (KAFKA-7435) Consider standardizing the config object pattern on interface/implementation.

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17517103#comment-17517103 ] Bruno Cadonna commented on KAFKA-7435: -- Removing from the 3.2.0 release since code f

[jira] [Commented] (KAFKA-6089) Transient failure in kafka.network.SocketServerTest.configureNewConnectionException

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17517105#comment-17517105 ] Bruno Cadonna commented on KAFKA-6089: -- Removing from the 3.2.0 release since code f

[jira] [Updated] (KAFKA-6089) Transient failure in kafka.network.SocketServerTest.configureNewConnectionException

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-6089: - Fix Version/s: (was: 3.2.0) > Transient failure in > kafka.network.SocketServerTest.configur

[jira] [Created] (KAFKA-13798) KafkaController should send LeaderAndIsr request when LeaderRecoveryState is altered

2022-04-04 Thread Jose Armando Garcia Sancio (Jira)
Jose Armando Garcia Sancio created KAFKA-13798: -- Summary: KafkaController should send LeaderAndIsr request when LeaderRecoveryState is altered Key: KAFKA-13798 URL: https://issues.apache.org/jira/brow

[GitHub] [kafka] junrao commented on a diff in pull request #11842: KAFKA-13687: Limiting the amount of bytes to be read in a segment logs

2022-04-04 Thread GitBox
junrao commented on code in PR #11842: URL: https://github.com/apache/kafka/pull/11842#discussion_r842151867 ## core/src/main/scala/kafka/tools/DumpLogSegments.scala: ## @@ -430,6 +431,11 @@ object DumpLogSegments { .describedAs("size") .ofType(classOf[java.lang.In

[jira] [Commented] (KAFKA-13093) KIP-724: Log compaction should write new segments with record version v2

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17517144#comment-17517144 ] Bruno Cadonna commented on KAFKA-13093: --- Removing from the 3.2.0 release since cod

[jira] [Updated] (KAFKA-13093) KIP-724: Log compaction should write new segments with record version v2

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-13093: -- Fix Version/s: (was: 3.2.0) > KIP-724: Log compaction should write new segments with recor

[jira] [Commented] (KAFKA-6080) Transactional EoS for source connectors

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17517145#comment-17517145 ] Bruno Cadonna commented on KAFKA-6080: -- Removing from the 3.2.0 release since code f

[jira] [Updated] (KAFKA-6080) Transactional EoS for source connectors

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-6080: - Fix Version/s: (was: 3.2.0) > Transactional EoS for source connectors > -

[jira] [Commented] (KAFKA-10233) KafkaConsumer polls in a tight loop if group is not authorized

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17517146#comment-17517146 ] Bruno Cadonna commented on KAFKA-10233: --- Removing from the 3.2.0 release since cod

[jira] [Updated] (KAFKA-10233) KafkaConsumer polls in a tight loop if group is not authorized

2022-04-04 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-10233: -- Fix Version/s: (was: 3.2.0) > KafkaConsumer polls in a tight loop if group is not authoriz

  1   2   >