Re: [PR] KAFKA-14588 ConfigEntityName move to server-common [kafka]

nizhikov commented on PR #14868: URL: https://github.com/apache/kafka/pull/14868#issuecomment-1870012227 @mimaison Can you, please, take a look. -- 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 th

[jira] [Comment Edited] (KAFKA-15558) Determine if Timer should be used elsewhere in PrototypeAsyncConsumer.updateFetchPositions()

[ https://issues.apache.org/jira/browse/KAFKA-15558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800672#comment-17800672 ] Phuc Hong Tran edited comment on KAFKA-15558 at 12/27/23 6:22 AM:

Re: [PR] KAFKA-15062: Adding ppc64le build stage [kafka]

Vaibhav-Nazare commented on PR #13817: URL: https://github.com/apache/kafka/pull/13817#issuecomment-1869973402 Hi Team , any updates on the plan to merge this PR? -- 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-15942: Implement ConsumerInterceptor [kafka]

Joker-5 closed pull request #14963: KAFKA-15942: Implement ConsumerInterceptor URL: https://github.com/apache/kafka/pull/14963 -- 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. T

Re: [PR] KAFKA-15942: Implement ConsumerInterceptor [kafka]

Joker-5 commented on PR #14963: URL: https://github.com/apache/kafka/pull/14963#issuecomment-1869912225 > @Joker-5 , makes sense and thanks for letting me know. We can close this PR then? Sure, I'll close this PR soon. -- This is an automated message from the Apache Git Service. To

Re: [PR] KAFKA-15739: KRaft support in ResetConsumerGroupOffsetTest [kafka]

linzihao1999 commented on PR #14686: URL: https://github.com/apache/kafka/pull/14686#issuecomment-1869898403 Hi @dengziming I trigger CI for 5 times and no flaky about it. https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-14686/8/pipeline https

[jira] [Commented] (KAFKA-15558) Determine if Timer should be used elsewhere in PrototypeAsyncConsumer.updateFetchPositions()

[ https://issues.apache.org/jira/browse/KAFKA-15558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800672#comment-17800672 ] Phuc Hong Tran commented on KAFKA-15558: [~kirktrue], please correct me if I'm w

Re: [PR] MINOR: set test global timeout as 10 mins [kafka]

jolshan commented on PR #15065: URL: https://github.com/apache/kafka/pull/15065#issuecomment-1869836473 Thanks @showuon for getting started with this. I noticed the first build still ran about 8h and hit an OOM issue. Looks like that will have to be addressed separately (which is ok). (edit

[jira] [Updated] (KAFKA-7957) Flaky Test DynamicBrokerReconfigurationTest#testMetricsReporterUpdate

[ https://issues.apache.org/jira/browse/KAFKA-7957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-7957: --- Fix Version/s: 3.8.0 (was: 3.7.0) > Flaky Test DynamicBrokerRe

[jira] [Updated] (KAFKA-6527) Transient failure in DynamicBrokerReconfigurationTest.testDefaultTopicConfig

[ https://issues.apache.org/jira/browse/KAFKA-6527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-6527: --- Fix Version/s: 3.8.0 (was: 3.7.0) > Transient failure in Dynam

[jira] [Commented] (KAFKA-6527) Transient failure in DynamicBrokerReconfigurationTest.testDefaultTopicConfig

[ https://issues.apache.org/jira/browse/KAFKA-6527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800640#comment-17800640 ] Stanislav Kozlovski commented on KAFKA-6527: Changing target fix version to 3

[jira] [Updated] (KAFKA-8280) Flaky Test DynamicBrokerReconfigurationTest#testUncleanLeaderElectionEnable

[ https://issues.apache.org/jira/browse/KAFKA-8280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-8280: --- Fix Version/s: 3.8.0 (was: 3.7.0) > Flaky Test DynamicBrokerRe

[jira] [Commented] (KAFKA-7957) Flaky Test DynamicBrokerReconfigurationTest#testMetricsReporterUpdate

[ https://issues.apache.org/jira/browse/KAFKA-7957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800639#comment-17800639 ] Stanislav Kozlovski commented on KAFKA-7957: Changing target fix version to 3

[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 ] Stanislav Kozlovski updated KAFKA-9578: --- Fix Version/s: 3.8.0 (was: 3.7.0) > Kafka Tiered Storage - Sys

[jira] [Commented] (KAFKA-9693) Kafka latency spikes caused by log segment flush on roll

[ https://issues.apache.org/jira/browse/KAFKA-9693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800636#comment-17800636 ] Stanislav Kozlovski commented on KAFKA-9693: Changing target fix version to 3

[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&focusedCommentId=17800637#comment-17800637 ] Stanislav Kozlovski commented on KAFKA-9578: Changing target fix version to 3

[jira] [Updated] (KAFKA-9693) Kafka latency spikes caused by log segment flush on roll

[ https://issues.apache.org/jira/browse/KAFKA-9693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-9693: --- Fix Version/s: 3.8.0 (was: 3.7.0) > Kafka latency spikes cause

[jira] [Commented] (KAFKA-8280) Flaky Test DynamicBrokerReconfigurationTest#testUncleanLeaderElectionEnable

[ https://issues.apache.org/jira/browse/KAFKA-8280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800638#comment-17800638 ] Stanislav Kozlovski commented on KAFKA-8280: Changing target fix version to 3

[jira] [Updated] (KAFKA-12319) Flaky test ConnectionQuotasTest.testListenerConnectionRateLimitWhenActualRateAboveLimit()

[ https://issues.apache.org/jira/browse/KAFKA-12319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-12319: Fix Version/s: 3.8.0 (was: 3.7.0) > Flaky test > Connectio

[jira] [Commented] (KAFKA-12319) Flaky test ConnectionQuotasTest.testListenerConnectionRateLimitWhenActualRateAboveLimit()

[ https://issues.apache.org/jira/browse/KAFKA-12319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800635#comment-17800635 ] Stanislav Kozlovski commented on KAFKA-12319: - Changing target fix version t

[jira] [Updated] (KAFKA-14690) OffsetCommit API Version 9

[ https://issues.apache.org/jira/browse/KAFKA-14690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-14690: Fix Version/s: 3.8.0 (was: 3.7.0) > OffsetCommit API Versio

[jira] [Updated] (KAFKA-12622) Automate LICENSE file validation

[ https://issues.apache.org/jira/browse/KAFKA-12622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-12622: Fix Version/s: 3.8.0 (was: 3.7.0) > Automate LICENSE file v

[jira] [Updated] (KAFKA-13097) Handle the requests gracefully to publish the events in TopicBasedRemoteLogMetadataManager when it is not yet initialized.

[ https://issues.apache.org/jira/browse/KAFKA-13097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-13097: Fix Version/s: (was: 3.7.0) > Handle the requests gracefully to publish the ev

[jira] [Updated] (KAFKA-15270) Integration tests for AsyncConsumer simple consume case

[ https://issues.apache.org/jira/browse/KAFKA-15270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-15270: Fix Version/s: (was: 3.7.0) > Integration tests for AsyncConsumer simple consu

[jira] [Updated] (KAFKA-15300) Include remotelog size in complete log size and also add local log size and remote log size separately in kafka-log-dirs tool.

[ https://issues.apache.org/jira/browse/KAFKA-15300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-15300: Fix Version/s: 3.8.0 (was: 3.7.0) > Include remotelog size

[jira] [Resolved] (KAFKA-12679) Rebalancing a restoring or running task may cause directory livelocking with newly created task

[ https://issues.apache.org/jira/browse/KAFKA-12679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski resolved KAFKA-12679. - Resolution: Fixed Marking this as done as per Lucas' comment that this is solved

[jira] [Updated] (KAFKA-15539) Client should stop fetching while partitions being revoked

[ https://issues.apache.org/jira/browse/KAFKA-15539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-15539: Fix Version/s: (was: 3.7.0) > Client should stop fetching while partitions bei

[jira] [Updated] (KAFKA-15540) Handle heartbeat and revocation when consumer leaves group

[ https://issues.apache.org/jira/browse/KAFKA-15540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-15540: Fix Version/s: (was: 3.7.0) > Handle heartbeat and revocation when consumer le

[jira] [Updated] (KAFKA-15543) Send HB request right after reconciliation completes

[ https://issues.apache.org/jira/browse/KAFKA-15543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-15543: Fix Version/s: (was: 3.7.0) > Send HB request right after reconciliation compl

[jira] [Updated] (KAFKA-15573) Implement auto-commit on partition assignment revocation

[ https://issues.apache.org/jira/browse/KAFKA-15573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-15573: Fix Version/s: (was: 3.7.0) > Implement auto-commit on partition assignment re

[jira] [Updated] (KAFKA-15694) New integration tests to have full coverage for preview

[ https://issues.apache.org/jira/browse/KAFKA-15694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-15694: Fix Version/s: (was: 3.7.0) > New integration tests to have full coverage for

[jira] [Updated] (KAFKA-15631) Do not send new heartbeat request while another one in-flight

[ https://issues.apache.org/jira/browse/KAFKA-15631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-15631: Fix Version/s: (was: 3.7.0) > Do not send new heartbeat request while another

[jira] [Updated] (KAFKA-15592) Member does not need to always try to join a group when a groupId is configured

[ https://issues.apache.org/jira/browse/KAFKA-15592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-15592: Fix Version/s: (was: 3.7.0) > Member does not need to always try to join a gro

[jira] [Updated] (KAFKA-15651) Investigate auto commit guarantees during Consumer.assign()

[ https://issues.apache.org/jira/browse/KAFKA-15651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-15651: Fix Version/s: (was: 3.7.0) > Investigate auto commit guarantees during Consum

[jira] [Updated] (KAFKA-15620) Duplicate remote log DELETE_SEGMENT metadata is generated when there are multiple leader epochs in the segment

[ https://issues.apache.org/jira/browse/KAFKA-15620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-15620: Fix Version/s: (was: 3.7.0) > Duplicate remote log DELETE_SEGMENT metadata is

[jira] [Updated] (KAFKA-15840) Correct initialization of ConsumerGroupHeartbeat by client

[ https://issues.apache.org/jira/browse/KAFKA-15840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-15840: Fix Version/s: (was: 3.7.0) > Correct initialization of ConsumerGroupHeartbeat

[jira] [Updated] (KAFKA-13152) Replace "buffered.records.per.partition" & "cache.max.bytes.buffering" with "{statestore.cache}/{input.buffer}.max.bytes"

[ https://issues.apache.org/jira/browse/KAFKA-13152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-13152: Fix Version/s: 3.8.0 (was: 3.7.0) > Replace "buffered.recor

[jira] [Commented] (KAFKA-13355) Shutdown broker eventually when unrecoverable exceptions like IOException encountered in RLMM.

[ https://issues.apache.org/jira/browse/KAFKA-13355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800632#comment-17800632 ] Stanislav Kozlovski commented on KAFKA-13355: - Changing target fix version t

[jira] [Commented] (KAFKA-13152) Replace "buffered.records.per.partition" & "cache.max.bytes.buffering" with "{statestore.cache}/{input.buffer}.max.bytes"

[ https://issues.apache.org/jira/browse/KAFKA-13152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800633#comment-17800633 ] Stanislav Kozlovski commented on KAFKA-13152: - Changing target fix version t

[jira] [Updated] (KAFKA-13355) Shutdown broker eventually when unrecoverable exceptions like IOException encountered in RLMM.

[ https://issues.apache.org/jira/browse/KAFKA-13355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-13355: Fix Version/s: 3.8.0 (was: 3.7.0) > Shutdown broker eventua

[jira] [Commented] (KAFKA-13421) Fix ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-13421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800631#comment-17800631 ] Stanislav Kozlovski commented on KAFKA-13421: - Changing target fix version t

[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&focusedCommentId=17800629#comment-17800629 ] Stanislav Kozlovski commented on KAFKA-13560: - Changing target fix version t

[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 ] Stanislav Kozlovski updated KAFKA-13560: Fix Version/s: 3.8.0 (was: 3.7.0) > Load indexes and data i

[jira] [Updated] (KAFKA-13421) Fix ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-13421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-13421: Fix Version/s: 3.8.0 (was: 3.7.0) > Fix > ConsumerBounceTe

[jira] [Commented] (KAFKA-14127) KIP-858: Handle JBOD broker disk failure in KRaft

[ https://issues.apache.org/jira/browse/KAFKA-14127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800628#comment-17800628 ] Stanislav Kozlovski commented on KAFKA-14127: - Changing target fix version t

[jira] [Updated] (KAFKA-14127) KIP-858: Handle JBOD broker disk failure in KRaft

[ https://issues.apache.org/jira/browse/KAFKA-14127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-14127: Fix Version/s: 3.8.0 (was: 3.7.0) > KIP-858: Handle JBOD br

Re: [PR] MINOR: New year code cleanup - include final keyword [kafka]

ijuma commented on PR #15072: URL: https://github.com/apache/kafka/pull/15072#issuecomment-1869779489 The streams final rule also includes local variables, etc (which is quite noisy). -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

Re: [PR] MINOR: New year code cleanup - include final keyword [kafka]

divijvaidya commented on PR #15072: URL: https://github.com/apache/kafka/pull/15072#issuecomment-1869776329 Thank you for the review @vamossagar12 . I didn't know about the checkstyle rule in streams. I will try & observe if enabling it for other modules leads to a large number of changes o

Re: [PR] MINOR: New year code cleanup - include final keyword [kafka]

divijvaidya commented on code in PR #15072: URL: https://github.com/apache/kafka/pull/15072#discussion_r1436615442 ## connect/api/src/main/java/org/apache/kafka/connect/data/SchemaProjector.java: ## @@ -37,13 +37,13 @@ public class SchemaProjector { -private static Set>

Re: [PR] MINOR: New year code cleanup - include final keyword [kafka]

divijvaidya commented on code in PR #15072: URL: https://github.com/apache/kafka/pull/15072#discussion_r1436615243 ## clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java: ## @@ -479,7 +479,7 @@ private static class NodeConnectionState { private f

Re: [PR] MINOR: New year code cleanup - include final keyword [kafka]

ijuma commented on code in PR #15072: URL: https://github.com/apache/kafka/pull/15072#discussion_r1436613486 ## clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java: ## @@ -479,7 +479,7 @@ private static class NodeConnectionState { private final S

[jira] [Resolved] (KAFKA-15493) Ensure system tests work with Java 21

[ https://issues.apache.org/jira/browse/KAFKA-15493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-15493. - Resolution: Fixed We can mark this as fixed. I ran the system tests with Java 21 and the results

[jira] [Updated] (KAFKA-15493) Ensure system tests work with Java 21

[ https://issues.apache.org/jira/browse/KAFKA-15493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-15493: Fix Version/s: 3.7.0 (was: 3.8.0) > Ensure system tests work with Java 21 >

[jira] [Updated] (KAFKA-14132) Remaining PowerMock to Mockito tests

[ https://issues.apache.org/jira/browse/KAFKA-14132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-14132: Fix Version/s: 3.8.0 (was: 3.7.0) > Remaining PowerMock to

[jira] [Commented] (KAFKA-14132) Remaining PowerMock to Mockito tests

[ https://issues.apache.org/jira/browse/KAFKA-14132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800624#comment-17800624 ] Stanislav Kozlovski commented on KAFKA-14132: - Changing target fix version t

[jira] [Updated] (KAFKA-14186) Add unit tests for BatchFileWriter

[ https://issues.apache.org/jira/browse/KAFKA-14186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-14186: Fix Version/s: 3.8.0 (was: 3.7.0) > Add unit tests for Batc

[jira] [Commented] (KAFKA-14302) Infinite probing rebalance if a changelog topic got emptied

[ https://issues.apache.org/jira/browse/KAFKA-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800620#comment-17800620 ] Stanislav Kozlovski commented on KAFKA-14302: - Changing target fix version t

[jira] [Updated] (KAFKA-14323) KRaft broker time based snapshots

[ https://issues.apache.org/jira/browse/KAFKA-14323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-14323: Fix Version/s: 3.8.0 (was: 3.7.0) > KRaft broker time based

[jira] [Updated] (KAFKA-14145) Faster propagation of high-watermark in KRaft topic partitions

[ https://issues.apache.org/jira/browse/KAFKA-14145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-14145: Fix Version/s: 3.8.0 (was: 3.7.0) > Faster propagation of h

[jira] [Commented] (KAFKA-14186) Add unit tests for BatchFileWriter

[ https://issues.apache.org/jira/browse/KAFKA-14186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800621#comment-17800621 ] Stanislav Kozlovski commented on KAFKA-14186: - Changing target fix version t

[jira] [Commented] (KAFKA-14145) Faster propagation of high-watermark in KRaft topic partitions

[ https://issues.apache.org/jira/browse/KAFKA-14145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800622#comment-17800622 ] Stanislav Kozlovski commented on KAFKA-14145: - Changing target fix version t

[jira] [Updated] (KAFKA-14302) Infinite probing rebalance if a changelog topic got emptied

[ https://issues.apache.org/jira/browse/KAFKA-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-14302: Fix Version/s: 3.8.0 (was: 3.7.0) > Infinite probing rebala

[jira] [Commented] (KAFKA-14323) KRaft broker time based snapshots

[ https://issues.apache.org/jira/browse/KAFKA-14323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800619#comment-17800619 ] Stanislav Kozlovski commented on KAFKA-14323: - Changing target fix version t

[jira] [Commented] (KAFKA-14403) Snapshot failure metrics

[ https://issues.apache.org/jira/browse/KAFKA-14403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800618#comment-17800618 ] Stanislav Kozlovski commented on KAFKA-14403: - Changing target fix version t

[jira] [Updated] (KAFKA-14323) KRaft broker time based snapshots

[ https://issues.apache.org/jira/browse/KAFKA-14323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-14323: Fix Version/s: 3.7.0 > KRaft broker time based snapshots > ---

[jira] [Updated] (KAFKA-14403) Snapshot failure metrics

[ https://issues.apache.org/jira/browse/KAFKA-14403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-14403: Fix Version/s: 3.8.0 (was: 3.7.0) > Snapshot failure metric

[jira] [Updated] (KAFKA-14323) KRaft broker time based snapshots

[ https://issues.apache.org/jira/browse/KAFKA-14323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-14323: Fix Version/s: (was: 3.7.0) > KRaft broker time based snapshots >

[jira] [Commented] (KAFKA-14482) Move LogLoader to storage module

[ https://issues.apache.org/jira/browse/KAFKA-14482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800617#comment-17800617 ] Stanislav Kozlovski commented on KAFKA-14482: - Changing target fix version t

[jira] [Updated] (KAFKA-14482) Move LogLoader to storage module

[ https://issues.apache.org/jira/browse/KAFKA-14482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-14482: Fix Version/s: 3.8.0 (was: 3.7.0) > Move LogLoader to stora

[jira] [Commented] (KAFKA-14683) Replace EasyMock and PowerMock with Mockito in WorkerSinkTaskTest

[ https://issues.apache.org/jira/browse/KAFKA-14683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800616#comment-17800616 ] Stanislav Kozlovski commented on KAFKA-14683: - Changing target fix version t

[jira] [Updated] (KAFKA-14683) Replace EasyMock and PowerMock with Mockito in WorkerSinkTaskTest

[ https://issues.apache.org/jira/browse/KAFKA-14683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-14683: Fix Version/s: 3.8.0 (was: 3.7.0) > Replace EasyMock and Po

[jira] [Updated] (KAFKA-14908) Sporadic "Address already in use" when starting kafka cluster embedded within tests

[ https://issues.apache.org/jira/browse/KAFKA-14908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-14908: Fix Version/s: 3.8.0 (was: 3.7.0) > Sporadic "Address alrea

[jira] [Commented] (KAFKA-14877) refactor InMemoryLeaderEpochCheckpoint

[ https://issues.apache.org/jira/browse/KAFKA-14877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800615#comment-17800615 ] Stanislav Kozlovski commented on KAFKA-14877: - Changing target fix version t

[jira] [Commented] (KAFKA-14892) Harmonize package names in storage module

[ https://issues.apache.org/jira/browse/KAFKA-14892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800614#comment-17800614 ] Stanislav Kozlovski commented on KAFKA-14892: - Changing target fix version t

[jira] [Updated] (KAFKA-14892) Harmonize package names in storage module

[ https://issues.apache.org/jira/browse/KAFKA-14892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-14892: Fix Version/s: 3.8.0 (was: 3.7.0) > Harmonize package names

[jira] [Updated] (KAFKA-14877) refactor InMemoryLeaderEpochCheckpoint

[ https://issues.apache.org/jira/browse/KAFKA-14877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-14877: Fix Version/s: 3.8.0 (was: 3.7.0) > refactor InMemoryLeader

[jira] [Commented] (KAFKA-14908) Sporadic "Address already in use" when starting kafka cluster embedded within tests

[ https://issues.apache.org/jira/browse/KAFKA-14908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800613#comment-17800613 ] Stanislav Kozlovski commented on KAFKA-14908: - Changing target fix version t

[jira] [Updated] (KAFKA-14911) Add system tests for rolling upgrade path of KIP-904

[ https://issues.apache.org/jira/browse/KAFKA-14911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-14911: Fix Version/s: 3.8.0 (was: 3.7.0) > Add system tests for ro

[jira] [Commented] (KAFKA-14911) Add system tests for rolling upgrade path of KIP-904

[ https://issues.apache.org/jira/browse/KAFKA-14911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800612#comment-17800612 ] Stanislav Kozlovski commented on KAFKA-14911: - Changing target fix version t

[jira] [Commented] (KAFKA-14915) Option to consume multiple partitions that have their data in remote storage for the target offsets.

[ https://issues.apache.org/jira/browse/KAFKA-14915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800611#comment-17800611 ] Stanislav Kozlovski commented on KAFKA-14915: - Changing target fix version t

[jira] [Updated] (KAFKA-14915) Option to consume multiple partitions that have their data in remote storage for the target offsets.

[ https://issues.apache.org/jira/browse/KAFKA-14915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-14915: Fix Version/s: 3.8.0 (was: 3.7.0) > Option to consume multi

[jira] [Updated] (KAFKA-16034) AsyncKafkaConsumer will get Invalid Request error when trying to rejoin on fenced/unknown member Id

[ https://issues.apache.org/jira/browse/KAFKA-16034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-16034: Fix Version/s: 3.8.0 (was: 3.7.0) > AsyncKafkaConsumer will

[jira] [Updated] (KAFKA-14928) Metrics collection contends on lock with log cleaning

[ https://issues.apache.org/jira/browse/KAFKA-14928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-14928: Fix Version/s: 3.8.0 (was: 3.7.0) > Metrics collection cont

[jira] [Commented] (KAFKA-14928) Metrics collection contends on lock with log cleaning

[ https://issues.apache.org/jira/browse/KAFKA-14928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800610#comment-17800610 ] Stanislav Kozlovski commented on KAFKA-14928: - Changing target fix version t

[jira] [Commented] (KAFKA-16034) AsyncKafkaConsumer will get Invalid Request error when trying to rejoin on fenced/unknown member Id

[ https://issues.apache.org/jira/browse/KAFKA-16034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800609#comment-17800609 ] Stanislav Kozlovski commented on KAFKA-16034: - Changing target fix version t

[jira] [Updated] (KAFKA-14945) Add Serializer#serializeToByteBuffer() to reduce memory copying

[ https://issues.apache.org/jira/browse/KAFKA-14945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-14945: Fix Version/s: 3.8.0 (was: 3.7.0) > Add Serializer#serializ

[jira] [Updated] (KAFKA-15038) Use topic id/name mapping from the Metadata cache in the RemoteLogManager

[ https://issues.apache.org/jira/browse/KAFKA-15038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-15038: Fix Version/s: 3.8.0 (was: 3.7.0) > Use topic id/name mappi

[jira] [Commented] (KAFKA-14954) Use BufferPools to optimize allocation in RemoteLogInputStream

[ https://issues.apache.org/jira/browse/KAFKA-14954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800607#comment-17800607 ] Stanislav Kozlovski commented on KAFKA-14954: - Changing target fix version t

[jira] [Commented] (KAFKA-15038) Use topic id/name mapping from the Metadata cache in the RemoteLogManager

[ https://issues.apache.org/jira/browse/KAFKA-15038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800606#comment-17800606 ] Stanislav Kozlovski commented on KAFKA-15038: - Changing target fix version t

[jira] [Updated] (KAFKA-14954) Use BufferPools to optimize allocation in RemoteLogInputStream

[ https://issues.apache.org/jira/browse/KAFKA-14954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-14954: Fix Version/s: 3.8.0 (was: 3.7.0) > Use BufferPools to opti

[jira] [Commented] (KAFKA-14945) Add Serializer#serializeToByteBuffer() to reduce memory copying

[ https://issues.apache.org/jira/browse/KAFKA-14945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800608#comment-17800608 ] Stanislav Kozlovski commented on KAFKA-14945: - Changing target fix version t

[jira] [Commented] (KAFKA-15038) Use topic id/name mapping from the Metadata cache in the RemoteLogManager

[ https://issues.apache.org/jira/browse/KAFKA-15038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800605#comment-17800605 ] Stanislav Kozlovski commented on KAFKA-15038: - Changing target fix version t

[jira] [Updated] (KAFKA-15057) Use new interface ZstdBufferDecompressingStreamNoFinalizer from zstd-jni

[ https://issues.apache.org/jira/browse/KAFKA-15057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-15057: Fix Version/s: 3.8.0 (was: 3.7.0) > Use new interface ZstdB

[jira] [Updated] (KAFKA-15132) Implement disable & re-enablement for Tiered Storage

[ https://issues.apache.org/jira/browse/KAFKA-15132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-15132: Fix Version/s: 3.8.0 (was: 3.7.0) > Implement disable & re-

[jira] [Commented] (KAFKA-15057) Use new interface ZstdBufferDecompressingStreamNoFinalizer from zstd-jni

[ https://issues.apache.org/jira/browse/KAFKA-15057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800604#comment-17800604 ] Stanislav Kozlovski commented on KAFKA-15057: - Changing target fix version t

[jira] [Commented] (KAFKA-15094) Add RemoteIndexCache metrics like misses/evictions/load-failures.

[ https://issues.apache.org/jira/browse/KAFKA-15094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800603#comment-17800603 ] Stanislav Kozlovski commented on KAFKA-15094: - Changing target fix version t

[jira] [Updated] (KAFKA-15094) Add RemoteIndexCache metrics like misses/evictions/load-failures.

[ https://issues.apache.org/jira/browse/KAFKA-15094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-15094: Fix Version/s: 3.8.0 (was: 3.7.0) > Add RemoteIndexCache me

[jira] [Commented] (KAFKA-15132) Implement disable & re-enablement for Tiered Storage

[ https://issues.apache.org/jira/browse/KAFKA-15132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800602#comment-17800602 ] Stanislav Kozlovski commented on KAFKA-15132: - Changing target fix version t

[jira] [Commented] (KAFKA-15495) KRaft partition truncated when the only ISR member restarts with an empty disk

[ https://issues.apache.org/jira/browse/KAFKA-15495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800601#comment-17800601 ] José Armando García Sancio commented on KAFKA-15495: [~rndgstn] , th

[jira] [Commented] (KAFKA-15140) Improve TopicCommandIntegrationTest to be less flaky

[ https://issues.apache.org/jira/browse/KAFKA-15140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800600#comment-17800600 ] Stanislav Kozlovski commented on KAFKA-15140: - Changing target fix version t

  1   2   3   >