[jira] [Resolved] (KAFKA-19567) Purgatory should clear up after share consumers are stopped

2025-08-10 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-19567. --- Fix Version/s: 4.2.0 Resolution: Fixed > Purgatory should clear up after sh

[jira] [Resolved] (KAFKA-19464) remove findNextFetchOffset.set(true) from acknowledge and release acquired records functionality

2025-08-07 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-19464. --- Fix Version/s: 4.2.0 Resolution: Fixed > remove findNextFetchOffset.set(true) f

[jira] [Resolved] (KAFKA-19502) During write state call processing, a batch can be split into offsets which is not accounted for

2025-08-06 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-19502. --- Fix Version/s: 4.2.0 Resolution: Not A Problem > During write state call process

[jira] [Resolved] (KAFKA-19437) Review incidence of null metadata image in share coordinator

2025-08-04 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-19437. --- Resolution: Fixed > Review incidence of null metadata image in share coordina

[jira] [Resolved] (KAFKA-19476) Improve state transition handling in SharePartition

2025-08-01 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-19476. --- Fix Version/s: 4.2.0 Resolution: Fixed > Improve state transition handling

Re: [DISCUSS] KIP-XXXX: Add max record count limit to FetchRequest

2025-07-29 Thread Apoorv Mittal
Hi Corki, Thanks for the KIP. You might want to start a new thread with a corrected subject i.e. include the KIP number in the subject for better tracking. Regards, Apoorv Mittal On Tue, Jul 29, 2025 at 2:27 PM Corki Oraen wrote: > Thanks, I’ve updated the KIP. It’s now available

[jira] [Resolved] (KAFKA-19555) Restrict records acquisition post max inflight records

2025-07-29 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-19555. --- Fix Version/s: 4.2.0 Resolution: Fixed > Restrict records acquisition post

Re: Request for Confluence Edit Permission

2025-07-28 Thread Apoorv Mittal
Hi Corki, You should have permissions on confluence/wiki to create KIP and pages. Please let us know if you face any issues. Regards, Apoorv Mittal On Mon, Jul 28, 2025 at 5:28 PM Corki Oraen wrote: > > > > I just created a Confluence account, but it seems that the approval > &

Re: Request for Confluence Edit Permission

2025-07-28 Thread Apoorv Mittal
Hi Corki, Somehow I don't see the account on Confluence/Wiki with that username. Did you sign up for Confluence as well, however the jira account does exist? https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=50859233#KafkaImprovementProposals-Started Regards, Apoorv Mittal

[jira] [Created] (KAFKA-19555) Restrict records acquisition post max inflight records

2025-07-28 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-19555: - Summary: Restrict records acquisition post max inflight records Key: KAFKA-19555 URL: https://issues.apache.org/jira/browse/KAFKA-19555 Project: Kafka

[jira] [Resolved] (KAFKA-19499) Correct the logger name in PersisterStateManager

2025-07-24 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-19499. --- Fix Version/s: 4.2.0 Resolution: Fixed > Correct the logger name

Re: [VOTE] KIP-1147: Improve consistency of command-line arguments

2025-07-22 Thread Apoorv Mittal
Thanks Andrew, it makes sense. +1 (binding) Regards, Apoorv Mittal On Tue, Jul 22, 2025 at 4:49 PM Andrew Schofield < andrew_schofield_j...@outlook.com> wrote: > Hi Apoorv, > 1) Yes, I think "kafka-streams-groups.sh" has been written since I > originally > wrote t

Re: [VOTE] KIP-1147: Improve consistency of command-line arguments

2025-07-22 Thread Apoorv Mittal
e should change that to --bootstrap-server as well? Regards, Apoorv Mittal On Tue, Jul 22, 2025 at 9:51 AM Omnia Ibrahim wrote: > Thanks Andrew for the KIP. The inconsistency always drives me crazy. > +1 (binding) > > Regards, > Omnia > > On 21 Jul 2025, at 09:48, Andre

[jira] [Created] (KAFKA-19513) Flaky test: AclControlManagerTest.testDeleteExceedsMaxRecords()

2025-07-16 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-19513: - Summary: Flaky test: AclControlManagerTest.testDeleteExceedsMaxRecords() Key: KAFKA-19513 URL: https://issues.apache.org/jira/browse/KAFKA-19513 Project: Kafka

Re: [ANNOUNCE] New Kafka PMC member: Lucas Brutschy

2025-07-15 Thread Apoorv Mittal
Congratulations Lucas! Regards, Apoorv Mittal On Tue, Jul 15, 2025 at 9:53 AM Bruno Cadonna wrote: > Congrats! Very well deserved! > > Best, > Bruno > > On 15.07.25 10:44, Mickael Maison wrote: > > Congratulations Lucas! > > > > Thanks, > > Micka

[jira] [Created] (KAFKA-19496) Failing test: DescribeStreamsGroupTest.testDescribeMultipleStreamsGroupWithMembersAndVerboseOptions()

2025-07-11 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-19496: - Summary: Failing test: DescribeStreamsGroupTest.testDescribeMultipleStreamsGroupWithMembersAndVerboseOptions() Key: KAFKA-19496 URL: https://issues.apache.org/jira/browse/KAFKA

[jira] [Created] (KAFKA-19493) Incorrect rate metric with larger window size

2025-07-10 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-19493: - Summary: Incorrect rate metric with larger window size Key: KAFKA-19493 URL: https://issues.apache.org/jira/browse/KAFKA-19493 Project: Kafka Issue Type

Re: [DISCUSS] Apache Kafka 4.1.0 release

2025-07-03 Thread Apoorv Mittal
Thanks, the PR is merged. Regards, Apoorv Mittal On Thu, Jul 3, 2025 at 7:11 PM Mickael Maison wrote: > Hi Apoorv, > > Yes you can go ahead and merge it in 4.1. > > Thanks, > Mickael > > On Thu, Jul 3, 2025 at 6:48 PM Apoorv Mittal > wrote: > > > > Hi M

Re: [DISCUSS] Apache Kafka 4.1.0 release

2025-07-03 Thread Apoorv Mittal
erged in trunk and patch for 4.1 is available: https://github.com/apache/kafka/pull/20100. Please let me know if I can merge it to the 4.1 branch. Regards, Apoorv Mittal On Wed, Jul 2, 2025 at 5:19 PM Andrew Schofield < andrew_schofield_j...@outlook.com> wrote: > Thanks. PR m

[jira] [Created] (KAFKA-19436) Acquisition lock timeout can't find some offsets to release

2025-06-25 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-19436: - Summary: Acquisition lock timeout can't find some offsets to release Key: KAFKA-19436 URL: https://issues.apache.org/jira/browse/KAFKA-19436 Project:

Re: [ANNOUNCE] New Kafka Committer: Omnia Ibrahim

2025-06-25 Thread Apoorv Mittal
Congrats Omnia! Great to hear! Regards, Apoorv Mittal On Wed, Jun 25, 2025 at 4:39 PM Kuan-Po Tseng wrote: > Congrats Omnia! > Well deserved. > > On Wed, Jun 25, 2025 at 11:34 PM Josep Prat > wrote: > > > Congrats Omnia!! > > > > Best, > > > >

Re: [ANNOUNCE] New Kafka PMC Member: José Armando García Sancio

2025-06-16 Thread Apoorv Mittal
Congratulations Jose! Regards, Apoorv Mittal On Mon, Jun 16, 2025 at 2:46 PM TengYao Chi wrote: > Congrats José! > > Cheers, > TengYao > > Lianet M. 於 2025年6月16日 週一 下午9:38寫道: > > > Congrats Jose! Great news! > > > > Cheers, > > > > Liane

[jira] [Resolved] (KAFKA-19389) High memory consumption for completed share fetch requests

2025-06-10 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-19389. --- Resolution: Fixed > High memory consumption for completed share fetch reque

[jira] [Resolved] (KAFKA-19386) Incorrect ExpirationReaper thread names from DelayedOperationPurgatory

2025-06-09 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-19386. --- Resolution: Fixed > Incorrect ExpirationReaper thread names from DelayedOperationPurgat

[jira] [Created] (KAFKA-19389) High memory consumption for completed share fetch requests

2025-06-08 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-19389: - Summary: High memory consumption for completed share fetch requests Key: KAFKA-19389 URL: https://issues.apache.org/jira/browse/KAFKA-19389 Project: Kafka

[jira] [Created] (KAFKA-19386) Incorrect ExpirationReaper thread names from DelayedOperationPurgatory

2025-06-06 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-19386: - Summary: Incorrect ExpirationReaper thread names from DelayedOperationPurgatory Key: KAFKA-19386 URL: https://issues.apache.org/jira/browse/KAFKA-19386 Project

[jira] [Resolved] (KAFKA-19346) Move LogReadResult to server module

2025-05-30 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-19346. --- Fix Version/s: 4.1.0 Resolution: Fixed > Move LogReadResult to server mod

[jira] [Resolved] (KAFKA-17809) Fix flaky test: testExplicitAcknowledgementCommitAsync

2025-05-30 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-17809. --- Fix Version/s: 4.1.0 Resolution: Fixed The issue has been fixed as part of other

[jira] [Reopened] (KAFKA-16092) Queues for Kafka

2025-05-29 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal reopened KAFKA-16092: --- > Queues for Kafka > > > Key:

[jira] [Resolved] (KAFKA-19285) Improve test coverage for SharePartitionManager

2025-05-29 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-19285. --- Fix Version/s: 4.1.0 Resolution: Fixed > Improve test coverage

[jira] [Resolved] (KAFKA-19204) Timeouts in coordinator runtime operations can break share group initialization and deletion

2025-05-29 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-19204. --- Fix Version/s: 4.1.0 Resolution: Fixed > Timeouts in coordinator runtime operati

[jira] [Resolved] (KAFKA-19189) Handle deletion of __share_group_state topic in share coordinator

2025-05-29 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-19189. --- Fix Version/s: 4.1.0 Resolution: Fixed > Handle deletion of __share_group_st

[jira] [Resolved] (KAFKA-16092) Queues for Kafka

2025-05-29 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-16092. --- Fix Version/s: 4.1.0 Assignee: Sushant Mahajan (was: Andrew Schofield

[jira] [Resolved] (KAFKA-19310) Missing mocks for DelayedShareFetchTest tests related to Memory Records slicing

2025-05-28 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-19310. --- Fix Version/s: 4.1.0 Resolution: Fixed > Missing mocks for DelayedShareFetchT

Re: [VOTE] KIP-1103: Additional metrics for cooperative consumption

2025-05-27 Thread Apoorv Mittal
hough still represents ratio but as percentage because only int or long can be recorded for histogram and meter. Regards, Apoorv Mittal On Fri, Nov 15, 2024 at 9:28 AM Apoorv Mittal wrote: > Thanks everyone for the feedback and votes! > > I have added the voting thread on the KIP a

[jira] [Resolved] (KAFKA-19291) Increase the timeout of remote storage share fetch requests in purgatory

2025-05-21 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-19291. --- Fix Version/s: 4.1.0 Resolution: Fixed > Increase the timeout of remote stor

[jira] [Created] (KAFKA-19312) Share partition fetch locks concurrent thread release

2025-05-19 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-19312: - Summary: Share partition fetch locks concurrent thread release Key: KAFKA-19312 URL: https://issues.apache.org/jira/browse/KAFKA-19312 Project: Kafka

[jira] [Resolved] (KAFKA-19226) Add test_console_share_consumer system test

2025-05-19 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-19226. --- Fix Version/s: 4.1.0 Resolution: Fixed > Add test_console_share_consumer system t

[jira] [Resolved] (KAFKA-19217) ShareConsumerTest.testComplexShareConsumer is unreliable

2025-05-19 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-19217. --- Fix Version/s: 4.1.0 Resolution: Fixed > ShareConsumerTest.testComplexShareConsu

Re: [DISCUSS] KIP-1130: Add metrics indicating the connection count exceeds

2025-05-19 Thread Apoorv Mittal
ming convention for yammer metrics is different than other kafka metrics i.e. follows pascal casing. Regards, Apoorv Mittal On 2025/04/13 13:43:20 TengYao Chi wrote: > Hi Chia-Ping > > chia_0: Thanks for pointing that out. I have fixed it. > > Best Regards, > TengYao > &

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

2025-05-19 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-17894. --- Resolution: Done > Additional metrics for cooperative consumpt

[jira] [Resolved] (KAFKA-19253) Improve metadata handling for share version using feature listeners

2025-05-15 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-19253. --- Fix Version/s: 4.1.0 Resolution: Fixed > Improve metadata handling for share vers

[jira] [Resolved] (KAFKA-19231) Handle fetch request when share session cache is full

2025-05-15 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-19231. --- Fix Version/s: 4.1.0 Resolution: Fixed > Handle fetch request when share sess

[jira] [Resolved] (KAFKA-19281) Add metadata version check to enable share coordinator timer tasks.

2025-05-15 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-19281. --- Fix Version/s: 4.1.0 Resolution: Fixed > Add metadata version check to enable sh

[jira] [Created] (KAFKA-19285) Imrove test coverage for SharePartitionManager

2025-05-15 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-19285: - Summary: Imrove test coverage for SharePartitionManager Key: KAFKA-19285 URL: https://issues.apache.org/jira/browse/KAFKA-19285 Project: Kafka Issue Type

[jira] [Resolved] (KAFKA-19116) Deletion of share group offsets does not reset the position as expected

2025-05-14 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-19116. --- Resolution: Fixed > Deletion of share group offsets does not reset the position as expec

[jira] [Resolved] (KAFKA-19258) Release acquired records for members whose share session is evicted due to connection drop

2025-05-14 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-19258. --- Fix Version/s: 4.1.0 Resolution: Fixed > Release acquired records for members wh

[jira] [Resolved] (KAFKA-19215) Handle share partition fetch lock cleanly in DelayedShareFetch to avoid a member incorrectly releasing a share partition's fetch lock

2025-05-07 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-19215. --- Fix Version/s: 4.1.0 Resolution: Fixed > Handle share partition fetch lock clea

[jira] [Resolved] (KAFKA-19241) Reuse the same socket on subsequent share requests in ShareFetchAcknowledgeRequestTest

2025-05-07 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-19241. --- Fix Version/s: 4.1.0 Resolution: Fixed > Reuse the same socket on subsequent sh

[jira] [Resolved] (KAFKA-19227) Fix performance for share fetch with piggyback acknowledgements

2025-05-06 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-19227. --- Fix Version/s: 4.1.0 Resolution: Fixed > Fix performance for share fetch w

[jira] [Created] (KAFKA-19245) Update defaults for preview of queues configurations

2025-05-06 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-19245: - Summary: Update defaults for preview of queues configurations Key: KAFKA-19245 URL: https://issues.apache.org/jira/browse/KAFKA-19245 Project: Kafka Issue

[jira] [Resolved] (KAFKA-19133) Support fetching for multiple remote fetch topic partitions in a single share fetch request

2025-05-05 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-19133. --- Fix Version/s: 4.1.0 Resolution: Fixed > Support fetching for multiple remote fe

[jira] [Created] (KAFKA-19232) Handle share session limit reached error in clients

2025-05-02 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-19232: - Summary: Handle share session limit reached error in clients Key: KAFKA-19232 URL: https://issues.apache.org/jira/browse/KAFKA-19232 Project: Kafka Issue

[jira] [Resolved] (KAFKA-19172) Handle the evictions metric in ShareSessionCache

2025-05-02 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-19172. --- Resolution: Won't Fix Change is not required as we still stick with existing m

[jira] [Resolved] (KAFKA-17942) Fix testAcknowledgementCommitCallbackInvalidRecordStateException

2025-05-02 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-17942. --- Resolution: Cannot Reproduce >

[jira] [Created] (KAFKA-19227) Fix performance for share fetch with piggyback acknowledgements

2025-05-01 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-19227: - Summary: Fix performance for share fetch with piggyback acknowledgements Key: KAFKA-19227 URL: https://issues.apache.org/jira/browse/KAFKA-19227 Project: Kafka

[jira] [Resolved] (KAFKA-18889) Make records in ShareFetchResponse non-nullable

2025-04-25 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-18889. --- Fix Version/s: 4.1.0 Resolution: Fixed > Make records in ShareFetchResponse

[jira] [Resolved] (KAFKA-19081) Share session capacity and eviction

2025-04-24 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-19081. --- Fix Version/s: 4.1.0 Resolution: Duplicate > Share session capacity and evict

[jira] [Resolved] (KAFKA-18170) Periodic snapshots for cold share partitions

2025-04-24 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-18170. --- Fix Version/s: 4.1.0 Resolution: Fixed > Periodic snapshots for cold sh

[jira] [Resolved] (KAFKA-18879) Formatter for share group specific records in __consumer_offsets

2025-04-24 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-18879. --- Fix Version/s: 4.1.0 Resolution: Duplicate > Formatter for share group speci

[jira] [Resolved] (KAFKA-19159) Remove time based eviction of share sessions from the cache

2025-04-22 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-19159. --- Resolution: Fixed > Remove time based eviction of share sessions from the ca

Re: [ANNOUNCE] New committer: Apoorv Mittal

2025-04-11 Thread Apoorv Mittal
Thank you so much everyone! I really appreciate it. I'm excited to be joining the Kafka committer community. Regards, Apoorv Mittal On Fri, Apr 11, 2025 at 7:56 AM Yash Mayya wrote: > Congratulations Apoorv! > > On Thu, Apr 10, 2025 at 9:28 PM Matthias J. Sax wrote: >

[jira] [Created] (KAFKA-19063) Send MaxRecords in share fetch request

2025-04-01 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-19063: - Summary: Send MaxRecords in share fetch request Key: KAFKA-19063 URL: https://issues.apache.org/jira/browse/KAFKA-19063 Project: Kafka Issue Type: Sub

[jira] [Created] (KAFKA-19019) Verify Share Fetch with Tiered Storage

2025-03-20 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-19019: - Summary: Verify Share Fetch with Tiered Storage Key: KAFKA-19019 URL: https://issues.apache.org/jira/browse/KAFKA-19019 Project: Kafka Issue Type: Sub

[jira] [Created] (KAFKA-19020) Handle strict max fetch records in share fetch

2025-03-20 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-19020: - Summary: Handle strict max fetch records in share fetch Key: KAFKA-19020 URL: https://issues.apache.org/jira/browse/KAFKA-19020 Project: Kafka Issue Type

[jira] [Created] (KAFKA-19018) Send acquisition time in Share Fetch Response

2025-03-20 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-19018: - Summary: Send acquisition time in Share Fetch Response Key: KAFKA-19018 URL: https://issues.apache.org/jira/browse/KAFKA-19018 Project: Kafka Issue Type

Re: [ANNOUNCE] Apache Kafka 4.0.0

2025-03-18 Thread Apoorv Mittal
Congratulations! A new milestone for Apache Kafka, thanks David for running the release. Regards, Apoorv Mittal On Tue, Mar 18, 2025 at 4:06 PM Mickael Maison wrote: > Congratulations! > > This release is a major milestone for Apache Kafka. > Thanks David for running the release

[jira] [Resolved] (KAFKA-18936) Share fetch stuck when records are larger than fetch max bytes

2025-03-12 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-18936. --- Resolution: Fixed > Share fetch stuck when records are larger than fetch max by

[jira] [Resolved] (KAFKA-18832) ShareFetch behaviour seems incorrect when MaxBytes is less than record size

2025-03-12 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-18832. --- Resolution: Fixed > ShareFetch behaviour seems incorrect when MaxBytes is less than rec

[jira] [Resolved] (KAFKA-18918) Share partition lock held for onComplete exception

2025-03-06 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-18918. --- Fix Version/s: 4.1.0 Resolution: Fixed > Share partition lock held for onCompl

[jira] [Created] (KAFKA-18936) Share fetch stuck when records are larger than fetch max bytes

2025-03-06 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-18936: - Summary: Share fetch stuck when records are larger than fetch max bytes Key: KAFKA-18936 URL: https://issues.apache.org/jira/browse/KAFKA-18936 Project: Kafka

[jira] [Created] (KAFKA-18918) Share partition lock held for onComplete exception

2025-03-04 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-18918: - Summary: Share partition lock held for onComplete exception Key: KAFKA-18918 URL: https://issues.apache.org/jira/browse/KAFKA-18918 Project: Kafka Issue

[jira] [Resolved] (KAFKA-18878) Implement ShareSessionCache and DelayedShareFetchMetrics metrics for share fetch

2025-03-03 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-18878. --- Fix Version/s: 4.1.0 Resolution: Fixed > Implement ShareSessionCache

[jira] [Resolved] (KAFKA-18734) Implement share partition metrics for share fetch

2025-02-28 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-18734. --- Resolution: Fixed > Implement share partition metrics for share fe

[jira] [Resolved] (KAFKA-18522) Limit fetch records batches as per acquired records

2025-02-28 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-18522. --- Fix Version/s: 4.1.0 Resolution: Fixed The first PR is merged and for MemoryRecords

[jira] [Created] (KAFKA-18889) Make records in ShareFetchResponse non-nullable

2025-02-27 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-18889: - Summary: Make records in ShareFetchResponse non-nullable Key: KAFKA-18889 URL: https://issues.apache.org/jira/browse/KAFKA-18889 Project: Kafka Issue Type

[jira] [Created] (KAFKA-18878) Implement share session cache metrics for share fetch

2025-02-26 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-18878: - Summary: Implement share session cache metrics for share fetch Key: KAFKA-18878 URL: https://issues.apache.org/jira/browse/KAFKA-18878 Project: Kafka

[jira] [Created] (KAFKA-18855) MemoryRecords should have slice API

2025-02-24 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-18855: - Summary: MemoryRecords should have slice API Key: KAFKA-18855 URL: https://issues.apache.org/jira/browse/KAFKA-18855 Project: Kafka Issue Type: Sub-task

[jira] [Resolved] (KAFKA-18733) Implement share group metrics for share fetch

2025-02-22 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-18733. --- Resolution: Fixed > Implement share group metrics for share fe

[jira] [Created] (KAFKA-18794) Flaky test: KafkaShareConsumerTest.testVerifyFetchAndCloseImplicit

2025-02-13 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-18794: - Summary: Flaky test: KafkaShareConsumerTest.testVerifyFetchAndCloseImplicit Key: KAFKA-18794 URL: https://issues.apache.org/jira/browse/KAFKA-18794 Project: Kafka

[jira] [Created] (KAFKA-18734) Implement share partition metrics for share fetch

2025-02-05 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-18734: - Summary: Implement share partition metrics for share fetch Key: KAFKA-18734 URL: https://issues.apache.org/jira/browse/KAFKA-18734 Project: Kafka Issue

[jira] [Created] (KAFKA-18733) Implement share group metrics for share fetch

2025-02-05 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-18733: - Summary: Implement share group metrics for share fetch Key: KAFKA-18733 URL: https://issues.apache.org/jira/browse/KAFKA-18733 Project: Kafka Issue Type

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

2025-02-05 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal reopened KAFKA-17894: --- Reopening the issue as creating sub taks for the respective PRs. > Additional metrics

[jira] [Resolved] (KAFKA-18732) Implement broker topic metrics for share fetch

2025-02-05 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-18732. --- Resolution: Fixed > Implement broker topic metrics for share fe

[jira] [Created] (KAFKA-18732) Implement broker topic metrics for share fetch

2025-02-05 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-18732: - Summary: Implement broker topic metrics for share fetch Key: KAFKA-18732 URL: https://issues.apache.org/jira/browse/KAFKA-18732 Project: Kafka Issue Type

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

2025-01-30 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-18683: - Summary: File records slice errors when sliced for moved start position Key: KAFKA-18683 URL: https://issues.apache.org/jira/browse/KAFKA-18683 Project: Kafka

[jira] [Created] (KAFKA-18650) Investigate RemoteLogManager exception in mocked tests

2025-01-26 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-18650: - Summary: Investigate RemoteLogManager exception in mocked tests Key: KAFKA-18650 URL: https://issues.apache.org/jira/browse/KAFKA-18650 Project: Kafka

[jira] [Created] (KAFKA-18640) Tota[lProduce|Fetch]RequestsPerSec broker topic metric tracks metric incorrectly

2025-01-24 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-18640: - Summary: Tota[lProduce|Fetch]RequestsPerSec broker topic metric tracks metric incorrectly Key: KAFKA-18640 URL: https://issues.apache.org/jira/browse/KAFKA-18640

[jira] [Resolved] (KAFKA-17853) Console share consumer is not terminated immediately

2025-01-22 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-17853. --- Resolution: Cannot Reproduce > Console share consumer is not terminated immediat

[jira] [Created] (KAFKA-18522) Limit fetch records batches as per acquired records

2025-01-14 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-18522: - Summary: Limit fetch records batches as per acquired records Key: KAFKA-18522 URL: https://issues.apache.org/jira/browse/KAFKA-18522 Project: Kafka Issue

[jira] [Created] (KAFKA-18514) Refactor share module to server and server-common

2025-01-14 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-18514: - Summary: Refactor share module to server and server-common Key: KAFKA-18514 URL: https://issues.apache.org/jira/browse/KAFKA-18514 Project: Kafka Issue

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

2025-01-08 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-18452: - Summary: Integrate share fetch batch size in share fetch Key: KAFKA-18452 URL: https://issues.apache.org/jira/browse/KAFKA-18452 Project: Kafka Issue Type

[jira] [Created] (KAFKA-18335) Remove deprecated metrics as part of KIP-1109 in Kafka-5.0

2024-12-20 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-18335: - Summary: Remove deprecated metrics as part of KIP-1109 in Kafka-5.0 Key: KAFKA-18335 URL: https://issues.apache.org/jira/browse/KAFKA-18335 Project: Kafka

Re: [VOTE] KIP-1109: Unifying Kafka Consumer Topic Metrics

2024-12-17 Thread Apoorv Mittal
Thanks everyone for voting and feedback. The vote has passed with 3 binding votes (Chia, Andrew and Jun). Regards, Apoorv Mittal On Mon, Dec 16, 2024 at 6:25 PM Jun Rao wrote: > Hi, Apoorv, > > Thanks for the KIP. +1 > > Jun > > On Thu, Dec 12, 2024 at 4:26 PM A

Re: [DISCUSS] KIP-1109: Unifying Kafka Consumer Topic Metrics

2024-12-13 Thread Apoorv Mittal
Hi Andrew, Thanks, I have corrected the text. Regards, Apoorv Mittal On Fri, Dec 13, 2024 at 1:56 PM Andrew Schofield < andrew_schofield_j...@outlook.com> wrote: > Hi Apoorv, > Thanks for the KIP. Just one small error that is probably worth fixing. > > AS1: It says &qu

Re: [DISCUSS] KIP-1109: Unifying Kafka Consumer Topic Metrics

2024-12-12 Thread Apoorv Mittal
Thanks Chia. I have started the voting thread: https://lists.apache.org/thread/fvn9r9lw55lyf971k6z4qnpnmq9tmm50 Regards, Apoorv Mittal On Thu, Dec 12, 2024 at 11:46 PM Chia-Ping Tsai wrote: > hi Apoorv > > Thank you for the update. It looks good to me. Perhaps we can start t

[VOTE] KIP-1109: Unifying Kafka Consumer Topic Metrics

2024-12-12 Thread Apoorv Mittal
Hi All, I would like to start vote on KIP-1109: https://cwiki.apache.org/confluence/display/KAFKA/KIP-1109%3A+Unifying+Kafka+Consumer+Topic+Metrics Discussion thread: https://lists.apache.org/thread/fvn9r9lw55lyf971k6z4qnpnmq9tmm50 Regards, Apoorv Mittal

Re: [DISCUSS] KIP-1109: Unifying Kafka Consumer Topic Metrics

2024-12-12 Thread Apoorv Mittal
Hi Jun and Chia, Thanks for the feedback and review. I have updated the KIP with details. There will be duplicate metrics as below, after the KIP, only for topics with period (.). [image: Screenshot 2024-12-12 at 15.44.37.png] Regards, Apoorv Mittal On Tue, Dec 10, 2024 at 3:46 AM Chia-Ping

Re: [ANNOUNCE] New committer: Andrew Schofield

2024-12-02 Thread Apoorv Mittal
Congratulations Andrew, much deserved. Great to hear :) Regards, Apoorv Mittal On Mon, Dec 2, 2024 at 2:26 PM Abhinav Dixit wrote: > Congratulations Andrew. Very happy for you :) > > On Mon, Dec 2, 2024 at 7:52 PM TengYao Chi wrote: > > > Congratulations Andrew >

Re: [DISCUSS] KIP-1109: Unifying Kafka Consumer Topic Metrics

2024-11-27 Thread Apoorv Mittal
recate old metrics and introduce new ones - I find the existing consumer metrics <https://kafka.apache.org/20/generated/consumer_metrics.html> named appropriately, hence finding it hard to come up with better names for new metrics, any suggestions if we go with this approach? Regards, Apoorv

  1   2   3   4   >