[jira] [Resolved] (KAFKA-18683) File records slice errors when sliced for moved start position

2025-01-31 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-18683. - Fix Version/s: 4.1.0 Resolution: Fixed merged the PR to trunk. > File records slice errors when

[jira] [Resolved] (KAFKA-18668) config/kraft/reconfig-server.properties no longer exists in quickstart

2025-01-29 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-18668. - Resolution: Implemented [~mimaison] : Thanks for the info. That PR covers this need. Closing this jira.

[jira] [Created] (KAFKA-18668) config/kraft/reconfig-server.properties no longer exists in quickstart

2025-01-29 Thread Jun Rao (Jira)
Jun Rao created KAFKA-18668: --- Summary: config/kraft/reconfig-server.properties no longer exists in quickstart Key: KAFKA-18668 URL: https://issues.apache.org/jira/browse/KAFKA-18668 Project: Kafka

[jira] [Resolved] (KAFKA-17894) Additional metrics for cooperative consumption

2025-01-24 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-17894. - Fix Version/s: 4.1.0 Resolution: Fixed Merged the PR to trunk. > Additional metrics for cooperat

[jira] [Created] (KAFKA-18641) AsyncKafkaConsumer could lose records with auto offset commit

2025-01-24 Thread Jun Rao (Jira)
Jun Rao created KAFKA-18641: --- Summary: AsyncKafkaConsumer could lose records with auto offset commit Key: KAFKA-18641 URL: https://issues.apache.org/jira/browse/KAFKA-18641 Project: Kafka Issue Ty

[jira] [Resolved] (KAFKA-18625) consumer client could get duplicated records if assigned partitions change quickly

2025-01-23 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-18625. - Resolution: Not A Problem > consumer client could get duplicated records if assigned partitions change

[jira] [Created] (KAFKA-18625) consumer client could get duplicated records if assigned partitions change quickly

2025-01-22 Thread Jun Rao (Jira)
Jun Rao created KAFKA-18625: --- Summary: consumer client could get duplicated records if assigned partitions change quickly Key: KAFKA-18625 URL: https://issues.apache.org/jira/browse/KAFKA-18625 Project: Kaf

[jira] [Resolved] (KAFKA-806) Index may not always observe log.index.interval.bytes

2025-01-17 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-806. --- Fix Version/s: 4.1.0 Resolution: Fixed merged [https://github.com/apache/kafka/pull/18012] to trunk >

[jira] [Resolved] (KAFKA-18452) Integrate share fetch batch size in share fetch

2025-01-15 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-18452. - Fix Version/s: 4.1.0 Resolution: Fixed merged the PR to trunk > Integrate share fetch batch size

[jira] [Created] (KAFKA-18479) remove keepPartitionMetadataFile in UnifiedLog and LogManager

2025-01-11 Thread Jun Rao (Jira)
Jun Rao created KAFKA-18479: --- Summary: remove keepPartitionMetadataFile in UnifiedLog and LogManager Key: KAFKA-18479 URL: https://issues.apache.org/jira/browse/KAFKA-18479 Project: Kafka Issue Ty

[jira] [Created] (KAFKA-18477) remove usage of OffsetForLeaderEpochRequest in AbstractFetcherThread

2025-01-10 Thread Jun Rao (Jira)
Jun Rao created KAFKA-18477: --- Summary: remove usage of OffsetForLeaderEpochRequest in AbstractFetcherThread Key: KAFKA-18477 URL: https://issues.apache.org/jira/browse/KAFKA-18477 Project: Kafka I

[jira] [Created] (KAFKA-18177) generate better helper code to support changing keys in request/response schema

2024-12-06 Thread Jun Rao (Jira)
Jun Rao created KAFKA-18177: --- Summary: generate better helper code to support changing keys in request/response schema Key: KAFKA-18177 URL: https://issues.apache.org/jira/browse/KAFKA-18177 Project: Kafka

[jira] [Resolved] (KAFKA-18052) Decouple the dependency of feature stable version to the metadata version

2024-12-05 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-18052. - Fix Version/s: 4.0.0 Resolution: Fixed merged the PR to trunk > Decouple the dependency of featu

[jira] [Resolved] (KAFKA-17783) Remove sharePartition from SharePartitionManager if the partition is deleted or becomes a follower

2024-12-04 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-17783. - Fix Version/s: 4.0.0 Resolution: Fixed merged the PR to trunk > Remove sharePartition from Share

[jira] [Resolved] (KAFKA-18027) MINOR: Correct DelayedOperationPurgatory code around adding of an already completed operation

2024-11-20 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-18027. - Fix Version/s: 4.0.0 Resolution: Fixed merged the PR to trunk. > MINOR: Correct DelayedOperation

[jira] [Resolved] (KAFKA-18022) fetchOffsetMetadata handling for minBytes estimation in both common/uncommon cases of share fetch

2024-11-16 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-18022. - Fix Version/s: 4.0.0 Resolution: Fixed merged the PR to trunk. > fetchOffsetMetadata handling fo

[jira] [Resolved] (KAFKA-17948) Potential issue during tryComplete and onComplete simultaneous calls to access global variables

2024-11-15 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-17948. - Fix Version/s: 4.0.0 Resolution: Fixed merged the PR to trunk > Potential issue during tryComple

[jira] [Resolved] (KAFKA-17510) Refactor code between SharePartitionManager and DelayedShareFetch for share partition initialization

2024-11-14 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-17510. - Fix Version/s: 4.0.0 Resolution: Fixed merged the PR to trunk > Refactor code between ShareParti

[jira] [Resolved] (KAFKA-17743) Add minBytes implementation to DelayedShareFetch

2024-11-07 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-17743. - Fix Version/s: 4.0.0 Resolution: Fixed merged the PR to trunk > Add minBytes implementation to D

[jira] [Resolved] (KAFKA-17941) TransactionStateManager.loadTransactionMetadata method may get stuck in an infinite loop

2024-11-05 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-17941. - Fix Version/s: 4.0.0 Resolution: Fixed merged the PR to trunk. > TransactionStateManager.loadTra

[jira] [Resolved] (KAFKA-6780) log cleaner shouldn't clean messages beyond high watermark

2024-11-01 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-6780. Resolution: Duplicate This is already fixed by https://issues.apache.org/jira/browse/KAFKA-5196 > log clea

[jira] [Resolved] (KAFKA-17803) Reconcile Differences in MockLog and KafkaMetadataLog `read` Implementation

2024-11-01 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-17803. - Fix Version/s: 4.0.0 Resolution: Fixed merged the PR to trunk > Reconcile Differences in MockLog

[jira] [Resolved] (KAFKA-17002) Integrate partition leader epoch in Share Partition

2024-10-30 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-17002. - Fix Version/s: 4.0.0 Resolution: Fixed merged the PR to trunk > Integrate partition leader epoch

[jira] [Resolved] (KAFKA-17804) optimize ReplicaManager.completeDelayedOperationsWhenNotPartitionLeader

2024-10-29 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-17804. - Resolution: Won't Fix > optimize ReplicaManager.completeDelayedOperationsWhenNotPartitionLeader > --

[jira] [Resolved] (KAFKA-17848) Resolve reliability issue on the broker post moving delayed share fetch purgatory to ReplicaManager

2024-10-26 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-17848. - Fix Version/s: 4.0.0 Resolution: Fixed merged the PR to trunk > Resolve reliability issue on the

[jira] [Resolved] (KAFKA-17774) Add capability for max fetch records in share fetch

2024-10-23 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-17774. - Fix Version/s: 4.0.0 Resolution: Fixed merged the PR to trunk > Add capability for max fetch rec

[jira] [Resolved] (KAFKA-17813) Create server connection id class encapsulating functionality for generation

2024-10-22 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-17813. - Fix Version/s: 4.0.0 Resolution: Fixed merged the PR to trunk > Create server connection id clas

[jira] [Resolved] (KAFKA-17545) Get rid of fetch queue in SharePartitionManager

2024-10-21 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-17545. - Fix Version/s: 4.0.0 Assignee: Apoorv Mittal (was: Abhinav Dixit) Resolution: Fixed Mer

[jira] [Resolved] (KAFKA-17742) Move DelayedShareFetchPurgatory declaration to ReplicaManager

2024-10-17 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-17742. - Fix Version/s: 4.0.0 Resolution: Fixed merged the PR to trunk. > Move DelayedShareFetchPurgatory

[jira] [Resolved] (KAFKA-17778) Clean up client instance cache on connection close

2024-10-17 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-17778. - Fix Version/s: 4.0.0 Resolution: Fixed merged the PR to trunk. > Clean up client instance cache

[jira] [Created] (KAFKA-17804) optimize ReplicaManager.completeDelayedOperationsWhenNotPartitionLeader

2024-10-15 Thread Jun Rao (Jira)
Jun Rao created KAFKA-17804: --- Summary: optimize ReplicaManager.completeDelayedOperationsWhenNotPartitionLeader Key: KAFKA-17804 URL: https://issues.apache.org/jira/browse/KAFKA-17804 Project: Kafka

[jira] [Created] (KAFKA-17801) RemoteLogManager may compute inaccurate upperBoundOffset for aborted txns

2024-10-15 Thread Jun Rao (Jira)
Jun Rao created KAFKA-17801: --- Summary: RemoteLogManager may compute inaccurate upperBoundOffset for aborted txns Key: KAFKA-17801 URL: https://issues.apache.org/jira/browse/KAFKA-17801 Project: Kafka

[jira] [Resolved] (KAFKA-17620) Simplify share partition acquire API

2024-10-10 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-17620. - Fix Version/s: 4.0.0 Resolution: Fixed merged the PR to trunk. > Simplify share partition acquir

[jira] [Resolved] (KAFKA-17703) Move DelayedActionsQueue outside DelayedShareFetch

2024-10-09 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-17703. - Fix Version/s: 4.0.0 Resolution: Fixed merged the PR to trunk. > Move DelayedActionsQueue outsid

[jira] [Resolved] (KAFKA-17509) Introduce a delayed action queue to complete purgatory actions outside purgatory code.

2024-10-04 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-17509. - Fix Version/s: 4.0.0 Resolution: Fixed Merged the PR to trunk. > Introduce a delayed action queu

[jira] [Resolved] (KAFKA-17076) logEndOffset could be lost due to log cleaning

2024-09-24 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-17076. - Fix Version/s: 4.0.0 Assignee: Vincent Jiang Resolution: Fixed Merged the PR to trunk.

[jira] [Resolved] (KAFKA-17400) Introduce a purgatory to deal with share fetch requests that cannot be completed instantaneously

2024-09-11 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-17400. - Fix Version/s: 4.0.0 Resolution: Fixed merged the PR to trunk. > Introduce a purgatory to deal w

[jira] [Resolved] (KAFKA-16746) Add support for share acknowledgement request in KafkaApis

2024-08-12 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-16746. - Fix Version/s: 4.0.0 Resolution: Fixed merged the PR to trunk > Add support for share acknowledg

[jira] [Resolved] (KAFKA-16745) Add support for share fetch request in KafkaApis

2024-08-06 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-16745. - Fix Version/s: 4.0.0 Resolution: Fixed Merged the PR to trunk. > Add support for share fetch req

[jira] [Resolved] (KAFKA-17230) Kafka consumer client doesn't report node request-latency metrics

2024-08-01 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-17230. - Fix Version/s: 3.9.0 Resolution: Fixed merged the PR to trunk > Kafka consumer client doesn't re

[jira] [Created] (KAFKA-17076) logEndOffset could be lost due to log cleaning

2024-07-03 Thread Jun Rao (Jira)
Jun Rao created KAFKA-17076: --- Summary: logEndOffset could be lost due to log cleaning Key: KAFKA-17076 URL: https://issues.apache.org/jira/browse/KAFKA-17076 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-16541) Potential leader epoch checkpoint file corruption on OS crash

2024-06-05 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-16541. - Fix Version/s: 4.0.0 Resolution: Fixed Merged the PR to trunk. > Potential leader epoch checkpoi

[jira] [Resolved] (KAFKA-16485) Fix broker metrics to follow kebab/hyphen case

2024-04-09 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-16485. - Fix Version/s: 3.8.0 Resolution: Fixed Merged the PR to trunk. > Fix broker metrics to follow ke

[jira] [Resolved] (KAFKA-15950) Serialize broker heartbeat requests

2024-03-25 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-15950. - Fix Version/s: 3.8.0 Resolution: Fixed merged the PR to trunk. > Serialize broker heartbeat requ

[jira] [Resolved] (KAFKA-16186) Implement broker metrics for client telemetry usage

2024-01-30 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-16186. - Fix Version/s: 3.8.0 Resolution: Fixed merged the PR to trunk > Implement broker metrics for cli

[jira] [Resolved] (KAFKA-15813) Improve implementation of client instance cache

2024-01-23 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-15813. - Fix Version/s: 3.8.0 Resolution: Fixed Merged to the PR to trunk. > Improve implementation of cl

[jira] [Resolved] (KAFKA-16137) ListClientMetricsResourcesResponse definition is missing field descriptions

2024-01-22 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-16137. - Fix Version/s: 3.8.0 Resolution: Fixed merged the PR to trunk. > ListClientMetricsResourcesRespo

[jira] [Resolved] (KAFKA-15811) implement capturing client port information from Socket Server

2024-01-19 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-15811. - Fix Version/s: 3.8.0 Resolution: Fixed merged the PR to trunk. > implement capturing client port

[jira] [Resolved] (KAFKA-15684) Add support to describe all subscriptions through utility

2023-12-06 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-15684. - Fix Version/s: 3.7.0 Resolution: Fixed merged the PR to trunk. > Add support to describe all sub

[jira] [Resolved] (KAFKA-15871) Implement kafka-client-metrics.sh tool

2023-12-06 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-15871. - Resolution: Fixed merged the PR to trunk > Implement kafka-client-metrics.sh tool > ---

[jira] [Resolved] (KAFKA-15831) List Client Metrics Configuration Resources

2023-12-05 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-15831. - Fix Version/s: 3.7.0 Resolution: Fixed merged the PR to trunk. > List Client Metrics Configurati

[jira] [Resolved] (KAFKA-15965) Test failure: org.apache.kafka.common.requests.BrokerRegistrationRequestTest

2023-12-04 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-15965. - Fix Version/s: 3.7.0 Assignee: Colin McCabe Resolution: Fixed This is fixed by https://g

[jira] [Created] (KAFKA-15950) CommunicationEvent should be scheduled with EarliestDeadlineFunction

2023-11-29 Thread Jun Rao (Jira)
Jun Rao created KAFKA-15950: --- Summary: CommunicationEvent should be scheduled with EarliestDeadlineFunction Key: KAFKA-15950 URL: https://issues.apache.org/jira/browse/KAFKA-15950 Project: Kafka I

[jira] [Resolved] (KAFKA-15046) Produce performance issue under high disk load

2023-11-29 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-15046. - Fix Version/s: 3.7.0 Resolution: Fixed merged the PR to trunk. > Produce performance issue under

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

2023-10-20 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-15651. - Resolution: Not A Problem > Investigate auto commit guarantees during Consumer.assign() > --

[jira] [Resolved] (KAFKA-15582) Clean shutdown detection, broker side

2023-10-19 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-15582. - Fix Version/s: 3.7.0 Resolution: Fixed merged the PR to trunk > Clean shutdown detection, broker

[jira] [Resolved] (KAFKA-14960) Metadata Request Manager and listTopics/partitionsFor API

2023-09-21 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-14960. - Fix Version/s: 3.7.0 Resolution: Fixed merged the PR to trunk. > Metadata Request Manager and li

[jira] [Resolved] (KAFKA-15306) Integrate committed offsets logic when updating fetching positions

2023-09-18 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-15306. - Fix Version/s: 3.7.0 Resolution: Fixed merged the PR to trunk > Integrate committed offsets logi

[jira] [Resolved] (KAFKA-15163) Implement validatePositions functionality for new KafkaConsumer

2023-09-13 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-15163. - Fix Version/s: 3.7.0 Resolution: Fixed This is covered in https://github.com/apache/kafka/pull/14

[jira] [Resolved] (KAFKA-15115) Implement resetPositions functionality in OffsetsRequestManager

2023-09-13 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-15115. - Fix Version/s: 3.7.0 Resolution: Fixed merged the PR to trunk > Implement resetPositions functio

[jira] [Resolved] (KAFKA-9800) [KIP-580] Client Exponential Backoff Implementation

2023-09-05 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-9800. Fix Version/s: 3.7.0 Resolution: Fixed Merged [https://github.com/apache/kafka/pull/14111] to trunk.

[jira] [Resolved] (KAFKA-15081) Implement new consumer offsetsForTimes

2023-09-01 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-15081. - Fix Version/s: 3.7.0 Resolution: Fixed merged the PR to trunk > Implement new consumer offsetsFo

[jira] [Resolved] (KAFKA-14965) Introduce OffsetsRequestManager to integrate ListOffsets requests into new consumer threading refactor

2023-09-01 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-14965. - Fix Version/s: 3.7.0 Resolution: Fixed merged the PR to trunk > Introduce OffsetsRequestManager

[jira] [Resolved] (KAFKA-14875) Implement Wakeup()

2023-08-29 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-14875. - Fix Version/s: 3.7.0 Resolution: Fixed merged the PR to trunk > Implement Wakeup() > ---

[jira] [Resolved] (KAFKA-14950) Implement assign() and assignment()

2023-07-21 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-14950. - Fix Version/s: 3.6.0 Resolution: Fixed merged the PR to trunk. > Implement assign() and assignme

[jira] [Resolved] (KAFKA-14966) Extract reusable common logic from OffsetFetcher

2023-06-08 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-14966. - Fix Version/s: 3.6.0 Resolution: Fixed Merged the PR to trunk. > Extract reusable common logic f

[jira] [Created] (KAFKA-15058) Improve the accuracy of Histogram in client metric

2023-06-05 Thread Jun Rao (Jira)
Jun Rao created KAFKA-15058: --- Summary: Improve the accuracy of Histogram in client metric Key: KAFKA-15058 URL: https://issues.apache.org/jira/browse/KAFKA-15058 Project: Kafka Issue Type: Improvem

[jira] [Resolved] (KAFKA-14561) Improve transactions experience for older clients by ensuring ongoing transaction

2023-04-12 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-14561. - Fix Version/s: 3.5.0 Resolution: Fixed merged the PR to trunk. > Improve transactions experience

[jira] [Resolved] (KAFKA-14617) Replicas with stale broker epoch should not be allowed to join the ISR

2023-04-07 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-14617. - Fix Version/s: 3.5.0 Resolution: Fixed merged all PRs to trunk. > Replicas with stale broker epo

[jira] [Resolved] (KAFKA-14685) TierStateMachine interface for building remote aux log

2023-02-24 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-14685. - Fix Version/s: 3.5.0 Resolution: Fixed merged the PR to trunk. > TierStateMachine interface for

[jira] [Resolved] (KAFKA-12736) KafkaProducer.flush holds onto completed ProducerBatch(s) until flush completes

2022-12-19 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-12736. - Fix Version/s: 3.0.0 Assignee: Lucas Bradstreet Resolution: Fixed > KafkaProducer.flush

[jira] [Resolved] (KAFKA-13369) Follower fetch protocol enhancements for tiered storage.

2022-12-17 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-13369. - Fix Version/s: 3.5.0 Resolution: Fixed merged the PR to trunk. > Follower fetch protocol enhance

[jira] [Resolved] (KAFKA-14303) Producer.send without record key and batch.size=0 goes into infinite loop

2022-11-28 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-14303. - Fix Version/s: 3.4.0 3.3.2 Resolution: Fixed Merged the PR to 3.3 and trunk.

[jira] [Resolved] (KAFKA-14321) max.compaction.lag.ms is not enforced accurately

2022-10-18 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-14321. - Resolution: Duplicate This actually duplicates KAFKA-10760. Closing this one. > max.compaction.lag.ms i

[jira] [Created] (KAFKA-14321) max.compaction.lag.ms is not enforced accurately

2022-10-18 Thread Jun Rao (Jira)
Jun Rao created KAFKA-14321: --- Summary: max.compaction.lag.ms is not enforced accurately Key: KAFKA-14321 URL: https://issues.apache.org/jira/browse/KAFKA-14321 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-4545) tombstone needs to be removed after delete.retention.ms has passed after it has been cleaned

2022-10-18 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-4545. Fix Version/s: 3.1.0 Resolution: Fixed This is fixed in KAFKA-8522. > tombstone needs to be removed

[jira] [Resolved] (KAFKA-14156) Built-in partitioner may create suboptimal batches with large linger.ms

2022-09-14 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-14156. - Assignee: Artem Livshits Resolution: Fixed Merged the PR to 3.3 and trunk. > Built-in partitioner

[jira] [Resolved] (KAFKA-14020) Performance regression in Producer

2022-07-20 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-14020. - Resolution: Fixed merged the PR to 3.3. > Performance regression in Producer >

[jira] [Resolved] (KAFKA-13803) Refactor Leader API Access

2022-06-03 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-13803. - Fix Version/s: 3.3.0 Resolution: Fixed merged the PR to trunk > Refactor Leader API Access > ---

[jira] [Resolved] (KAFKA-10888) Sticky partition leads to uneven product msg, resulting in abnormal delays in some partitions

2022-05-06 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-10888. - Fix Version/s: 3.3.0 Resolution: Fixed merged the PR to trunk. Thanks [~alivshits] for the design

[jira] [Resolved] (KAFKA-13815) Avoid reinitialization for a replica that is being deleted

2022-05-04 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-13815. - Fix Version/s: 3.3.0 Resolution: Fixed merged the PR to trunk > Avoid reinitialization for a rep

[jira] [Resolved] (KAFKA-13448) Kafka Producer Client Callback behaviour does not align with Javadoc

2022-04-26 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-13448. - Fix Version/s: 3.2.0 Assignee: Philip Nee Resolution: Fixed merged [https://github.com/a

[jira] [Resolved] (KAFKA-13687) Limit number of batches when using kafka-dump-log.sh

2022-04-06 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-13687. - Fix Version/s: 3.3.0 Resolution: Fixed merged the PR to trunk. > Limit number of batches when us

[jira] [Resolved] (KAFKA-12875) Change Log layer segment map mutations to avoid absence of active segment

2022-03-31 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-12875. - Fix Version/s: 3.3.0 Assignee: Yu Yang Resolution: Fixed Merged to trunk. > Change Log

[jira] [Resolved] (KAFKA-13723) max.compaction.lag.ms implemented incorrectly

2022-03-09 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-13723. - Resolution: Not A Problem > max.compaction.lag.ms implemented incorrectly >

[jira] [Created] (KAFKA-13723) max.compaction.lag.ms implemented incorrectly

2022-03-09 Thread Jun Rao (Jira)
Jun Rao created KAFKA-13723: --- Summary: max.compaction.lag.ms implemented incorrectly Key: KAFKA-13723 URL: https://issues.apache.org/jira/browse/KAFKA-13723 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-13407) Kafka controller out of service after ZK leader restart

2022-02-24 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-13407. - Resolution: Fixed > Kafka controller out of service after ZK leader restart > --

[jira] [Resolved] (KAFKA-13603) empty active segment can trigger recovery after clean shutdown and restart

2022-01-27 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-13603. - Fix Version/s: 3.2.0 Resolution: Fixed merged the PR to trunk. > empty active segment can trigge

[jira] [Resolved] (KAFKA-13544) Deadlock during shutting down kafka broker because of connectivity problem with zookeeper

2021-12-17 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-13544. - Fix Version/s: 3.2.0 Resolution: Fixed Merged the PR to trunk. > Deadlock during shutting down k

[jira] [Resolved] (KAFKA-13551) kafka-log4j-appender-2.1.1.jar Is cve-2021-44228 involved?

2021-12-16 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-13551. - Resolution: Information Provided The impact is described in [https://kafka.apache.org/cve-list] > kafk

[jira] [Resolved] (KAFKA-13202) KIP-768: Extend SASL/OAUTHBEARER with Support for OIDC

2021-10-28 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-13202. - Fix Version/s: 3.1.0 Resolution: Fixed merged the PR to trunk. > KIP-768: Extend SASL/OAUTHBEARE

[jira] [Resolved] (KAFKA-12802) Add a file based cache for consumed remote log metadata for each partition to avoid consuming again incase of broker restarts.

2021-10-11 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-12802. - Resolution: Fixed merged the PR to trunk > Add a file based cache for consumed remote log metadata for

[jira] [Resolved] (KAFKA-13305) NullPointerException in LogCleanerManager "uncleanable-bytes" gauge

2021-09-27 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-13305. - Fix Version/s: 3.1.0 Assignee: Vincent Jiang Resolution: Fixed merged the PR trunk. > N

[jira] [Resolved] (KAFKA-13070) LogManager shutdown races with periodic work scheduled by the instance

2021-09-23 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-13070. - Resolution: Duplicate > LogManager shutdown races with periodic work scheduled by the instance > ---

[jira] [Resolved] (KAFKA-13315) log layer exception during shutdown that caused an unclean shutdown

2021-09-23 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-13315. - Fix Version/s: 3.0.1 3.1.0 Resolution: Fixed merged the PR to trunk and 3.0.

[jira] [Created] (KAFKA-13313) In KRaft mode, CreateTopic should return the topic configs in the response

2021-09-20 Thread Jun Rao (Jira)
Jun Rao created KAFKA-13313: --- Summary: In KRaft mode, CreateTopic should return the topic configs in the response Key: KAFKA-13313 URL: https://issues.apache.org/jira/browse/KAFKA-13313 Project: Kafka

[jira] [Resolved] (KAFKA-8522) Tombstones can survive forever

2021-09-16 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-8522. Fix Version/s: 3.1.0 Assignee: Richard Yu Resolution: Fixed Finally, merged the PR to trunk

[jira] [Resolved] (KAFKA-12988) Change RLMM add/updateRemoteLogSegmentMetadata and putRemotePartitionDeleteMetadata APIS asynchronous.

2021-09-09 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-12988. - Fix Version/s: 3.1.0 Resolution: Fixed merged the PR to trunk. > Change RLMM add/updateRemoteLog

[jira] [Resolved] (KAFKA-13225) Controller skips sending UpdateMetadataRequest when shutting down broker doesnt host partitions

2021-09-02 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-13225. - Fix Version/s: 3.1.0 Resolution: Fixed merged the PR to trunk > Controller skips sending UpdateM

[jira] [Resolved] (KAFKA-13198) TopicsDelta doesn't update deleted topic when processing PartitionChangeRecord

2021-08-17 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-13198. - Resolution: Fixed merged the PR to 3.0 and trunk. > TopicsDelta doesn't update deleted topic when proce

  1   2   3   4   5   6   7   8   9   10   >