[GitHub] [kafka] yun-yun commented on pull request #11981: KAFKA-13791: Fix FetchResponse#`fetchData` and `forgottenTopics`: Assignment of lazy-initialized members should be the last step with double-

yun-yun commented on PR #11981: URL: https://github.com/apache/kafka/pull/11981#issuecomment-1088245743 Hi @showuon , can this PR be merged? -- 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

[GitHub] [kafka] ijuma commented on pull request #11991: KAFKA-13794: Fix comparator of inflightBatchesBySequence in TransactionManager

ijuma commented on PR #11991: URL: https://github.com/apache/kafka/pull/11991#issuecomment-1088215820 I agree we should include this in 3.1.1. Do we know if this has always been like this or if it regressed at some point? -- This is an automated message from the Apache Git Service. To

[GitHub] [kafka] ddrid commented on pull request #11991: KAFKA-13794: Fix comparator of inflightBatchesBySequence in TransactionManager

ddrid commented on PR #11991: URL: https://github.com/apache/kafka/pull/11991#issuecomment-1088209337 @hachikuji Thanks for your review! I've addressed your comments and please take a look -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [kafka] C0urante commented on pull request #5876: KAFKA-7509: Avoid passing most non-applicable properties to producer, consumer, and admin client

C0urante commented on PR #5876: URL: https://github.com/apache/kafka/pull/5876#issuecomment-1088179915 I've taken an alternative approach in https://github.com/apache/kafka/pull/11986. If anyone wants to take a look and either review the changes or take them for a spin locally, I'd

[GitHub] [kafka] hachikuji commented on a diff in pull request #11991: KAFKA-13794: Fix comparator of inflightBatchesBySequence in TransactionManager

hachikuji commented on code in PR #11991: URL: https://github.com/apache/kafka/pull/11991#discussion_r842258345 ## clients/src/test/java/org/apache/kafka/clients/producer/internals/TransactionManagerTest.java: ## @@ -674,6 +674,61 @@ public void

[GitHub] [kafka] hachikuji commented on a diff in pull request #11991: KAFKA-13794: Fix comparator of inflightBatchesBySequence in TransactionManager

hachikuji commented on code in PR #11991: URL: https://github.com/apache/kafka/pull/11991#discussion_r842248811 ## clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java: ## @@ -184,16 +184,22 @@ private void

[GitHub] [kafka] anatasiavela opened a new pull request, #11996: MINOR: Fix flaky testIdleConnection() test

anatasiavela opened a new pull request, #11996: URL: https://github.com/apache/kafka/pull/11996 The test expects that the connection becomes idle before the mock time is moved forward, but the processor thread runs concurrently and may run some activity on the connection after the mock

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

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

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

[ https://issues.apache.org/jira/browse/KAFKA-7509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517159#comment-17517159 ] Chris Egerton commented on KAFKA-7509: -- Hmm... I'm not able to reproduce this easily with Kafka

[jira] [Resolved] (KAFKA-13741) Cluster IDs should not have leading dash

[ https://issues.apache.org/jira/browse/KAFKA-13741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur resolved KAFKA-13741. -- Resolution: Fixed > Cluster IDs should not have leading dash >

[jira] [Updated] (KAFKA-13755) Broker heartbeat event should have deadline

[ https://issues.apache.org/jira/browse/KAFKA-13755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-13755: -- Fix Version/s: (was: 3.2.0) > Broker heartbeat event should have deadline >

[jira] [Commented] (KAFKA-13755) Broker heartbeat event should have deadline

[ https://issues.apache.org/jira/browse/KAFKA-13755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517155#comment-17517155 ] Bruno Cadonna commented on KAFKA-13755: --- Removing from the 3.2.0 release since code freeze has

[jira] [Updated] (KAFKA-10642) Expose the real stack trace if any exception occurred during SSL Client Trust Verification in extension

[ https://issues.apache.org/jira/browse/KAFKA-10642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-10642: -- Fix Version/s: (was: 3.2.0) > Expose the real stack trace if any exception occurred

[jira] [Commented] (KAFKA-10642) Expose the real stack trace if any exception occurred during SSL Client Trust Verification in extension

[ https://issues.apache.org/jira/browse/KAFKA-10642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517154#comment-17517154 ] Bruno Cadonna commented on KAFKA-10642: --- Removing from the 3.2.0 release since code freeze has

[jira] [Updated] (KAFKA-9803) Allow producers to recover gracefully from transaction timeouts

[ https://issues.apache.org/jira/browse/KAFKA-9803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-9803: - Fix Version/s: (was: 3.2.0) > Allow producers to recover gracefully from transaction

[jira] [Commented] (KAFKA-9803) Allow producers to recover gracefully from transaction timeouts

[ https://issues.apache.org/jira/browse/KAFKA-9803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517153#comment-17517153 ] Bruno Cadonna commented on KAFKA-9803: -- Removing from the 3.2.0 release since code freeze has

[jira] [Updated] (KAFKA-12842) Failing test: org.apache.kafka.connect.integration.ConnectWorkerIntegrationTest.testSourceTaskNotBlockedOnShutdownWithNonExistentTopic

[ https://issues.apache.org/jira/browse/KAFKA-12842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12842: -- Fix Version/s: (was: 3.2.0) > Failing test: >

[jira] [Commented] (KAFKA-12842) Failing test: org.apache.kafka.connect.integration.ConnectWorkerIntegrationTest.testSourceTaskNotBlockedOnShutdownWithNonExistentTopic

[ https://issues.apache.org/jira/browse/KAFKA-12842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517152#comment-17517152 ] Bruno Cadonna commented on KAFKA-12842: --- Removing from the 3.2.0 release since code freeze has

[jira] [Updated] (KAFKA-9910) Implement new transaction timed out error

[ https://issues.apache.org/jira/browse/KAFKA-9910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-9910: - Fix Version/s: (was: 3.2.0) > Implement new transaction timed out error >

[jira] [Commented] (KAFKA-9910) Implement new transaction timed out error

[ https://issues.apache.org/jira/browse/KAFKA-9910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517151#comment-17517151 ] Bruno Cadonna commented on KAFKA-9910: -- Removing from the 3.2.0 release since code freeze has

[jira] [Updated] (KAFKA-7493) Rewrite test_broker_type_bounce_at_start

[ https://issues.apache.org/jira/browse/KAFKA-7493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-7493: - Fix Version/s: (was: 3.2.0) > Rewrite test_broker_type_bounce_at_start >

[jira] [Commented] (KAFKA-7493) Rewrite test_broker_type_bounce_at_start

[ https://issues.apache.org/jira/browse/KAFKA-7493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517150#comment-17517150 ] Bruno Cadonna commented on KAFKA-7493: -- Removing from the 3.2.0 release since code freeze has

[jira] [Updated] (KAFKA-12641) Clear RemoteLogLeaderEpochState entry when it become empty.

[ https://issues.apache.org/jira/browse/KAFKA-12641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12641: -- Fix Version/s: (was: 3.2.0) > Clear RemoteLogLeaderEpochState entry when it become empty.

[jira] [Commented] (KAFKA-12641) Clear RemoteLogLeaderEpochState entry when it become empty.

[ https://issues.apache.org/jira/browse/KAFKA-12641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517149#comment-17517149 ] Bruno Cadonna commented on KAFKA-12641: --- Removing from the 3.2.0 release since code freeze has

[jira] [Updated] (KAFKA-9579) RLM fetch implementation by adding respective purgatory

[ https://issues.apache.org/jira/browse/KAFKA-9579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-9579: - Fix Version/s: (was: 3.2.0) > RLM fetch implementation by adding respective purgatory >

[jira] [Commented] (KAFKA-9579) RLM fetch implementation by adding respective purgatory

[ https://issues.apache.org/jira/browse/KAFKA-9579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517148#comment-17517148 ] Bruno Cadonna commented on KAFKA-9579: -- Removing from the 3.2.0 release since code freeze has

[jira] [Commented] (KAFKA-12176) Consider changing default log.message.timestamp.difference.max.ms

[ https://issues.apache.org/jira/browse/KAFKA-12176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517147#comment-17517147 ] Bruno Cadonna commented on KAFKA-12176: --- Removing from the 3.2.0 release since code freeze has

[jira] [Updated] (KAFKA-12176) Consider changing default log.message.timestamp.difference.max.ms

[ https://issues.apache.org/jira/browse/KAFKA-12176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12176: -- Fix Version/s: (was: 3.2.0) > Consider changing default

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

[ 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

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

[ https://issues.apache.org/jira/browse/KAFKA-10233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517146#comment-17517146 ] Bruno Cadonna commented on KAFKA-10233: --- Removing from the 3.2.0 release since code freeze has

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

[ 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-6080) Transactional EoS for source connectors

[ https://issues.apache.org/jira/browse/KAFKA-6080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517145#comment-17517145 ] Bruno Cadonna commented on KAFKA-6080: -- Removing from the 3.2.0 release since code freeze has

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

[ 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

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

[ https://issues.apache.org/jira/browse/KAFKA-13093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517144#comment-17517144 ] Bruno Cadonna commented on KAFKA-13093: --- Removing from the 3.2.0 release since code freeze has

[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

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")

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

Jose Armando Garcia Sancio created KAFKA-13798: -- Summary: KafkaController should send LeaderAndIsr request when LeaderRecoveryState is altered Key: KAFKA-13798 URL:

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

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

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

[ https://issues.apache.org/jira/browse/KAFKA-6089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517105#comment-17517105 ] Bruno Cadonna commented on KAFKA-6089: -- Removing from the 3.2.0 release since code freeze has

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

[ https://issues.apache.org/jira/browse/KAFKA-7435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517103#comment-17517103 ] Bruno Cadonna commented on KAFKA-7435: -- Removing from the 3.2.0 release since code freeze has

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

[ 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

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

[ https://issues.apache.org/jira/browse/KAFKA-13560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517100#comment-17517100 ] Bruno Cadonna commented on KAFKA-13560: --- Removing from the 3.2.0 release since code freeze has

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

[ 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

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

[ https://issues.apache.org/jira/browse/KAFKA-12616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517098#comment-17517098 ] Bruno Cadonna commented on KAFKA-12616: --- Removing from the 3.2.0 release since code freeze has

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

[ 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-13782) Producer may fail to add the correct partition to transaction

[ https://issues.apache.org/jira/browse/KAFKA-13782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517085#comment-17517085 ] Jason Gustafson commented on KAFKA-13782: - [~tombentley] Apologies for the delay. PR is up:

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

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-9990) Supporting transactions in tiered storage

[ https://issues.apache.org/jira/browse/KAFKA-9990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517034#comment-17517034 ] Bruno Cadonna commented on KAFKA-9990: -- Removing from the 3.2.0 release since code freeze has

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

[ 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

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

[ https://issues.apache.org/jira/browse/KAFKA-9578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517032#comment-17517032 ] Bruno Cadonna edited comment on KAFKA-9578 at 4/4/22 6:40 PM: -- Removing from

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

[ 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] [Commented] (KAFKA-9578) Kafka Tiered Storage - System Tests

[ https://issues.apache.org/jira/browse/KAFKA-9578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517032#comment-17517032 ] Bruno Cadonna commented on KAFKA-9578: -- Remove from the 3.2.0 release since code freeze has passed.

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

[ 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

[ https://issues.apache.org/jira/browse/KAFKA-9550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517030#comment-17517030 ] Bruno Cadonna edited comment on KAFKA-9550 at 4/4/22 6:40 PM: -- Removing from

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

[ https://issues.apache.org/jira/browse/KAFKA-9550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517030#comment-17517030 ] Bruno Cadonna commented on KAFKA-9550: -- Remove from the 3.2.0 release since code freeze has passed.

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

[ 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-12644) Add Missing Class-Level Javadoc to Descendants of org.apache.kafka.common.errors.ApiException

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

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

[ https://issues.apache.org/jira/browse/KAFKA-12644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517027#comment-17517027 ] Bruno Cadonna commented on KAFKA-12644: --- Removing from the 3.2.0 release since code freeze has

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

[ 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-9837) New RPC for notifying controller of failed replica

[ https://issues.apache.org/jira/browse/KAFKA-9837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517025#comment-17517025 ] Bruno Cadonna commented on KAFKA-9837: -- Removing from 3.2.0 release since code freeze has passed. >

[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

[ 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

[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

[ https://issues.apache.org/jira/browse/KAFKA-13411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517024#comment-17517024 ] Bruno Cadonna commented on KAFKA-13411: --- Removing from the 3.2.0 release since code freeze has

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

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

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

[ https://issues.apache.org/jira/browse/KAFKA-13331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517022#comment-17517022 ] Bruno Cadonna commented on KAFKA-13331: --- Removing from the 3.2.0 release since code freeze has

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

[ https://issues.apache.org/jira/browse/KAFKA-12878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516996#comment-17516996 ] Bruno Cadonna commented on KAFKA-12878: --- Removing from 3.2.0 relase since code freeze has passed.

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

[ 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

[ 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

[ 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

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

[ 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

[ 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] [Created] (KAFKA-13797) Adding metric to indicate metadata response outgoing bytes rate

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

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

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

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

[ https://issues.apache.org/jira/browse/KAFKA-7509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516992#comment-17516992 ] Chris Egerton commented on KAFKA-7509: -- [~mjsax] thanks for taking a look. RE

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

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

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

[ https://issues.apache.org/jira/browse/KAFKA-12291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516987#comment-17516987 ] Bruno Cadonna commented on KAFKA-12291: --- Removing from release 3.2.0 since code freeze has passed.

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

[ 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

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

[ https://issues.apache.org/jira/browse/KAFKA-13474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516984#comment-17516984 ] Bruno Cadonna commented on KAFKA-13474: --- Moving to the next release since code freeze for 3.2.0

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

[ 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-7509) Kafka Connect logs unnecessary warnings about unused configurations

[ https://issues.apache.org/jira/browse/KAFKA-7509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516979#comment-17516979 ] Matthias J. Sax commented on KAFKA-7509: Thanks for following up. – I briefly took a look. My

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

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

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

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

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

[ https://issues.apache.org/jira/browse/KAFKA-13159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516947#comment-17516947 ] Bruno Cadonna edited comment on KAFKA-13159 at 4/4/22 4:52 PM: --- [~mumrah]

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

[ 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] [Commented] (KAFKA-13159) Enable system tests for transactions in KRaft mode

[ https://issues.apache.org/jira/browse/KAFKA-13159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516947#comment-17516947 ] Bruno Cadonna commented on KAFKA-13159: --- [~mumrah] Same question as [~mimaison]: Can we close this

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

[ https://issues.apache.org/jira/browse/KAFKA-13295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516945#comment-17516945 ] Bruno Cadonna commented on KAFKA-13295: --- Removing from 3.2. release since code freeze passed. >

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

[ 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

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

[ 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

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

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

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

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:

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

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

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

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",

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

[ https://issues.apache.org/jira/browse/KAFKA-13684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516900#comment-17516900 ] Peter Cipov commented on KAFKA-13684: - hello [~guozhang]    We have investigated this further and

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

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

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

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] tombentley commented on pull request #11994: MINOR: Mention KAFKA-13748 in release notes

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

[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

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

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

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

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

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

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

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

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

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

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

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,

  1   2   >