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

2024-10-11 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-17778: - Summary: Clean up client instance cache on connection close Key: KAFKA-17778 URL: https://issues.apache.org/jira/browse/KAFKA-17778 Project: Kafka Issue

[jira] [Created] (KAFKA-17776) Add connection disconnect listener in socket server

2024-10-11 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-17776: - Summary: Add connection disconnect listener in socket server Key: KAFKA-17776 URL: https://issues.apache.org/jira/browse/KAFKA-17776 Project: Kafka Issue

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

2024-10-11 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-17774: - Summary: Add capability for max fetch records in share fetch Key: KAFKA-17774 URL: https://issues.apache.org/jira/browse/KAFKA-17774 Project: Kafka Issue

Re: [VOTE] KIP-1092: Extend Consumer#close with an option to leave the group or not

2024-10-11 Thread Apoorv Mittal
Hi TengYao, Thanks for the KIP. +1 (non-binding) Regards, Apoorv Mittal On Fri, Oct 11, 2024 at 12:55 AM Sophie Blee-Goldman wrote: > +1 (binding) > > Thanks for this KIP! > > On Mon, Oct 7, 2024 at 9:22 AM Kirk True wrote: > > > Hi TengYao, > > > > +1

[jira] [Created] (KAFKA-17760) Remove client instance from cache when received telemetry terminating request

2024-10-10 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-17760: - Summary: Remove client instance from cache when received telemetry terminating request Key: KAFKA-17760 URL: https://issues.apache.org/jira/browse/KAFKA-17760

[jira] [Resolved] (KAFKA-17626) Move common fetch related classes from storage to server-common

2024-10-09 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-17626. --- Resolution: Fixed > Move common fetch related classes from storage to server-com

[jira] [Created] (KAFKA-17731) Kafka consumer client sometimes elapses wait time for terminating telemetry push

2024-10-08 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-17731: - Summary: Kafka consumer client sometimes elapses wait time for terminating telemetry push Key: KAFKA-17731 URL: https://issues.apache.org/jira/browse/KAFKA-17731

[jira] [Resolved] (KAFKA-17522) Share partition acquire() need not return a future

2024-09-27 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-17522. --- Resolution: Duplicate > Share partition acquire() need not return a fut

[jira] [Resolved] (KAFKA-17482) Make share partition initialization async

2024-09-26 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-17482. --- Resolution: Fixed > Make share partition initialization as

[jira] [Resolved] (KAFKA-17483) Complete pending fetch request on broker shutdown

2024-09-26 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-17483. --- Resolution: Fixed > Complete pending fetch request on broker shutd

[jira] [Created] (KAFKA-17626) Move common fetch related classes from storage to storage-api

2024-09-26 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-17626: - Summary: Move common fetch related classes from storage to storage-api Key: KAFKA-17626 URL: https://issues.apache.org/jira/browse/KAFKA-17626 Project: Kafka

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

2024-09-26 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-17620: - Summary: Simplify share partition acquire API Key: KAFKA-17620 URL: https://issues.apache.org/jira/browse/KAFKA-17620 Project: Kafka Issue Type: Sub-task

Re: [VOTE] KIP-1043: Administration of groups

2024-09-23 Thread Apoorv Mittal
Hi Andrew, Thanks for the KIP, this will be very helpful. +1 (non-binding) Regards, Apoorv Mittal On Mon, Sep 23, 2024 at 11:38 AM Lianet M. wrote: > Hello Andrew, > > Thanks for the KIP. > > +1 (binding) > > Lianet > > On Mon, Sep 23, 2024, 3:37 a.m. Lucas Brutsch

[jira] [Created] (KAFKA-17577) May be record metrics on UnknownSubscriptionIdException

2024-09-18 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-17577: - Summary: May be record metrics on UnknownSubscriptionIdException Key: KAFKA-17577 URL: https://issues.apache.org/jira/browse/KAFKA-17577 Project: Kafka

[jira] [Created] (KAFKA-17482) Make share partition initialization async

2024-09-04 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-17482: - Summary: Make share partition initialization async Key: KAFKA-17482 URL: https://issues.apache.org/jira/browse/KAFKA-17482 Project: Kafka Issue Type: Sub

Re: [VOTE] KIP-1076: Metrics for client applications a KIP-714 extension

2024-09-03 Thread Apoorv Mittal
Thanks for the KIP, looking forward to it. +1 (non-binding) Regards, Apoorv Mittal On Tue, Sep 3, 2024 at 9:00 PM Matthias J. Sax wrote: > +1 (binding) > > On 9/3/24 8:56 AM, Andrew Schofield wrote: > > Thanks for the KIP. +1 (non-binding)

[jira] [Resolved] (KAFKA-17442) Implement persister error handling and make write calls async

2024-09-02 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-17442. --- Resolution: Fixed > Implement persister error handling and make write calls as

[jira] [Created] (KAFKA-17464) Flaky test: org.apache.kafka.clients.consumer.internals.AbstractCoordinatorTest.testWakeupAfterSyncGroupSentExternalCompletion

2024-09-01 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-17464: - Summary: Flaky test: org.apache.kafka.clients.consumer.internals.AbstractCoordinatorTest.testWakeupAfterSyncGroupSentExternalCompletion Key: KAFKA-17464 URL: https

[jira] [Reopened] (KAFKA-15896) Flaky test: shouldQuerySpecificStalePartitionStores() – org.apache.kafka.streams.integration.StoreQueryIntegrationTest

2024-09-01 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal reopened KAFKA-15896: --- Failed again: https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-16956/5/testReport

[jira] [Created] (KAFKA-17463) Flaky test: kafka.api.PlaintextAdminIntegrationTest."testShareGroups(String).quorum=kraft+kip932"

2024-09-01 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-17463: - Summary: Flaky test: kafka.api.PlaintextAdminIntegrationTest."testShareGroups(String).quorum=kraft+kip932" Key: KAFKA-17463 URL: https://issues.apache.org/jira/br

[jira] [Resolved] (KAFKA-17396) Fix releasing of session on clients final epoch

2024-08-29 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-17396. --- Resolution: Fixed > Fix releasing of session on clients final ep

[jira] [Created] (KAFKA-17442) Implement persister error handling and make write calls async

2024-08-29 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-17442: - Summary: Implement persister error handling and make write calls async Key: KAFKA-17442 URL: https://issues.apache.org/jira/browse/KAFKA-17442 Project: Kafka

[jira] [Resolved] (KAFKA-17283) Add integration test for Share Group heartbeat

2024-08-29 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-17283. --- Resolution: Fixed > Add integration test for Share Group heartb

Re: [ANNOUNCE] New committer: Lianet Magrans

2024-08-28 Thread Apoorv Mittal
Congratulations Lianet! Awesome! Regards, Apoorv Mittal On Wed, Aug 28, 2024 at 6:14 PM TengYao Chi wrote: > Congratulations, Lianet! > This recognition is well deserved. > > Philip Nee 於 2024年8月29日 週四 上午1:09寫道: > > > congrats! > > > > On Wed, Aug 2

[jira] [Created] (KAFKA-17396) Fix releasing of session on clients final epoch

2024-08-21 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-17396: - Summary: Fix releasing of session on clients final epoch Key: KAFKA-17396 URL: https://issues.apache.org/jira/browse/KAFKA-17396 Project: Kafka Issue Type

[jira] [Resolved] (KAFKA-17346) Refactor Share Sesssion Class to Server Module

2024-08-21 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-17346. --- Resolution: Fixed > Refactor Share Sesssion Class to Server Mod

Re: [DISCUSS] KIP-1076: Metrics for client applications a KIP-714 extension

2024-08-21 Thread Apoorv Mittal
Hi Bill, Thanks for addressing, looks good to me. Looking forward to implementation. Regards, Apoorv Mittal On Wed, Aug 21, 2024 at 8:14 PM Bill Bejeck wrote: > Hi Apoorv, > > Good call, I've updated the compatibility section with text about using > older brokers. > > -

Re: [DISCUSS] KIP-1076: Metrics for client applications a KIP-714 extension

2024-08-21 Thread Apoorv Mittal
Hi Bill, Thanks for the details. Sounds good to me. One last question: AM5: Do we need to capture any details around compatibility with older brokers which don't support KIP-714 or when telemetry APIs are not enabled on brokers (no configured receiver plugin)? Regards, Apoorv Mittal O

Re: [DISCUSS] KIP-1076: Metrics for client applications a KIP-714 extension

2024-08-20 Thread Apoorv Mittal
then how we will differentiate with external application metrics while emitting through JMXReporter of clients. Regards, Apoorv Mittal On Tue, Aug 20, 2024 at 8:09 PM Bill Bejeck wrote: > Hi Apoorv, > > Thanks for reading the KIP and commenting. Here are my answers to your > c

Re: [DISCUSS] KIP-1076: Metrics for client applications a KIP-714 extension

2024-08-20 Thread Apoorv Mittal
ig also defines `enable.metrics.push`, do we need that config or rely on client metric push config? Or all the clients will inherit the `enable.metrics.push` defined for Streams? Regards, Apoorv Mittal On Tue, Aug 20, 2024 at 10:21 AM Bruno Cadonna wrote: > Hi Bill, > > Thanks for the K

[jira] [Created] (KAFKA-17366) Flaky test: org.apache.kafka.tools.reassign.ReassignPartitionsCommandTest.testAlterReassignmentThrottle

2024-08-19 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-17366: - Summary: Flaky test: org.apache.kafka.tools.reassign.ReassignPartitionsCommandTest.testAlterReassignmentThrottle Key: KAFKA-17366 URL: https://issues.apache.org/jira/browse

[jira] [Created] (KAFKA-17365) Flaky test: org.apache.kafka.tools.reassign.ReassignPartitionsCommandTest.testProduceAndConsumeWithReassignmentInProgress

2024-08-19 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-17365: - Summary: Flaky test: org.apache.kafka.tools.reassign.ReassignPartitionsCommandTest.testProduceAndConsumeWithReassignmentInProgress Key: KAFKA-17365 URL: https

[jira] [Created] (KAFKA-17364) Flaky test: org.apache.kafka.streams.integration.QueryableStateIntegrationTest.shouldBeAbleQueryStandbyStateDuringRebalance()

2024-08-19 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-17364: - Summary: Flaky test: org.apache.kafka.streams.integration.QueryableStateIntegrationTest.shouldBeAbleQueryStandbyStateDuringRebalance() Key: KAFKA-17364 URL: https

[jira] [Created] (KAFKA-17363) Flaky test: kafka.api.PlaintextConsumerCommitTest.testAutoCommitOnRebalance(String, String).quorum=kraft+kip848.groupProtocol=consumer

2024-08-19 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-17363: - Summary: Flaky test: kafka.api.PlaintextConsumerCommitTest.testAutoCommitOnRebalance(String, String).quorum=kraft+kip848.groupProtocol=consumer Key: KAFKA-17363 URL: https

[jira] [Created] (KAFKA-17362) Flaky test: kafka.api.AuthorizerIntegrationTest."testDeleteRecordsWithWildCardAuth(String).quorum=kraft"

2024-08-19 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-17362: - Summary: Flaky test: kafka.api.AuthorizerIntegrationTest."testDeleteRecordsWithWildCardAuth(String).quorum=kraft" Key: KAFKA-17362 URL: https://issues.apache.org/j

[jira] [Created] (KAFKA-17351) Validate compacted topics start offset handling in Share Partition

2024-08-15 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-17351: - Summary: Validate compacted topics start offset handling in Share Partition Key: KAFKA-17351 URL: https://issues.apache.org/jira/browse/KAFKA-17351 Project: Kafka

[jira] [Created] (KAFKA-17346) Refactor Share Sesssion Class to Server Module

2024-08-15 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-17346: - Summary: Refactor Share Sesssion Class to Server Module Key: KAFKA-17346 URL: https://issues.apache.org/jira/browse/KAFKA-17346 Project: Kafka Issue Type

Re: [DISCUSS] KIP-1082: Enable ID Generation for Clients over the ConsumerGroupHeartbeat RPC

2024-08-14 Thread Apoorv Mittal
hat's true then shall delayed partition assignment can help benefit us from this situation as well? Regards, Apoorv Mittal On Wed, Aug 14, 2024 at 12:51 PM David Jacot wrote: > Hi Andrew, > > Personally, I don't like the lobby approach. It makes things more > complicated a

[jira] [Resolved] (KAFKA-16742) Add ShareGroupDescribe API support in GroupCoordinator

2024-08-08 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-16742. --- Resolution: Fixed > Add ShareGroupDescribe API support in GroupCoordina

[jira] [Created] (KAFKA-17288) Remove tracking member partition epoch for share groups

2024-08-07 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-17288: - Summary: Remove tracking member partition epoch for share groups Key: KAFKA-17288 URL: https://issues.apache.org/jira/browse/KAFKA-17288 Project: Kafka

[jira] [Created] (KAFKA-17283) Add integration test for Share Group heartbeat

2024-08-07 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-17283: - Summary: Add integration test for Share Group heartbeat Key: KAFKA-17283 URL: https://issues.apache.org/jira/browse/KAFKA-17283 Project: Kafka Issue Type

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

2024-07-31 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-17230: - Summary: Kafka consumer client doesn't report node request-latency metrics Key: KAFKA-17230 URL: https://issues.apache.org/jira/browse/KAFKA-17230 Project:

[jira] [Reopened] (KAFKA-15863) Handle push telemetry throttling with quota manager

2024-07-30 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal reopened KAFKA-15863: --- Reopening to introduce metric quota. > Handle push telemetry throttling with quota mana

Re: [VOTE] KIP-1068: New metrics for the new KafkaConsumer

2024-07-25 Thread Apoorv Mittal
Hi Brenden, The metrics look good. Thanks for the KIP. +1 (Non-Binding) Regards, Apoorv Mittal On Thu, Jul 25, 2024 at 5:04 PM Philip Nee wrote: > Hi Brenden, > > Thanks for the KIP. +1 (non-binding). > > P > > On Thu, Jul 25, 2024 at 6:25 AM Lianet M. wrote: > &g

Re: [DISCUSS] KIP-1068: KIP-1068: New JMX Metrics for AsyncKafkaConsumer

2024-07-19 Thread Apoorv Mittal
y name for `unsent-requests-queue-size` intended as `org.apache.kafka.consumer.unsent.requests.size`, or it should be corrected to ` org.apache.kafka.consumer.unsent.requests.queue.size`? AM2: Regards, Apoorv Mittal +44 7721681581 On Mon, Jul 15, 2024 at 2:45 PM Andrew Schofield wrote: > Hi Bren

Re: [DISCUSS] KIP-1043: Administration of groups

2024-07-18 Thread Apoorv Mittal
t's unclear to me why it's needed as the client and server supporting `kafka-groups.sh` will be post ListGroups v5 API anyways hence TypesFilter will be supported in both client and server. Am I missing something here? Regards, Apoorv Mittal +44 7721681581 On Wed, Jul 17, 2024 at 6:26 PM A

[jira] [Resolved] (KAFKA-16743) Add support for share group heartbeat in KafkaApis

2024-07-16 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-16743. --- Resolution: Fixed > Add support for share group heartbeat in KafkaA

[jira] [Resolved] (KAFKA-16744) Add support for share group describe in KafkaApis

2024-07-16 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-16744. --- Resolution: Fixed > Add support for share group describe in KafkaA

[jira] [Resolved] (KAFKA-16756) Implement max delivery count functionality in SharePartition

2024-07-02 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-16756. --- Resolution: Done Already merged as part of other code changes in Share Partition

[jira] [Created] (KAFKA-17047) Refactor Consumer group and shared classes with Share to modern package

2024-06-27 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-17047: - Summary: Refactor Consumer group and shared classes with Share to modern package Key: KAFKA-17047 URL: https://issues.apache.org/jira/browse/KAFKA-17047 Project

[jira] [Resolved] (KAFKA-16999) Integrate persister read API in Partition leader initilization

2024-06-24 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-16999. --- Resolution: Done > Integrate persister read API in Partition leader initilizat

[jira] [Resolved] (KAFKA-16749) Implement share fetch messages

2024-06-24 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-16749. --- Resolution: Done > Implement share fetch messa

[jira] [Resolved] (KAFKA-16748) Implement share response handling in SharePartitionManager

2024-06-24 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-16748. --- Resolution: Fixed > Implement share response handling in SharePartitionMana

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

2024-06-20 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-17002: - Summary: Integrate partition leader epoch in Share Partition Key: KAFKA-17002 URL: https://issues.apache.org/jira/browse/KAFKA-17002 Project: Kafka Issue

[jira] [Created] (KAFKA-16999) Integrate persister read API in Partition leader initilization

2024-06-19 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-16999: - Summary: Integrate persister read API in Partition leader initilization Key: KAFKA-16999 URL: https://issues.apache.org/jira/browse/KAFKA-16999 Project: Kafka

[jira] [Resolved] (KAFKA-16753) Implement acknowledge functionality in SharePartition

2024-06-19 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-16753. --- Resolution: Fixed > Implement acknowledge functionality in SharePartit

[jira] [Resolved] (KAFKA-16752) Implement acquire functionality in SharePartition

2024-06-14 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-16752. --- Resolution: Done > Implement acquire functionality in SharePartit

[jira] [Created] (KAFKA-16950) Define Persister and Share Coordinator RPCs

2024-06-13 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-16950: - Summary: Define Persister and Share Coordinator RPCs Key: KAFKA-16950 URL: https://issues.apache.org/jira/browse/KAFKA-16950 Project: Kafka Issue Type

Re: Build hanging

2024-06-07 Thread Apoorv Mittal
Hi Sophie, Yes the PR should also fix the tests in other class you mentioned. I have validated locally and attached details in the PR for successful run on local. - Regards, Apoorv Mittal > On 8 Jun 2024, at 02:24, Sophie Blee-Goldman wrote: > > Thanks for the quick fix! > >

Re: Build hanging

2024-06-07 Thread Apoorv Mittal
Hi, Please find the fix for the issue: https://github.com/apache/kafka/pull/16249 Regards, Apoorv Mittal +44 7721681581 On Sat, Jun 8, 2024 at 2:09 AM Sophie Blee-Goldman wrote: > Thanks for jumping on this guys, and nice find Haruki > > I agree with Luke that we should disable the

[jira] [Created] (KAFKA-16914) Add Shage Group dynamic and broker configs

2024-06-07 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-16914: - Summary: Add Shage Group dynamic and broker configs Key: KAFKA-16914 URL: https://issues.apache.org/jira/browse/KAFKA-16914 Project: Kafka Issue Type: Sub

[jira] [Created] (KAFKA-16905) Thread block in describe topics API in Admin Client

2024-06-06 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-16905: - Summary: Thread block in describe topics API in Admin Client Key: KAFKA-16905 URL: https://issues.apache.org/jira/browse/KAFKA-16905 Project: Kafka Issue

[jira] [Created] (KAFKA-16822) Abstract consumer group in coordinator to share functionality with share group

2024-05-22 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-16822: - Summary: Abstract consumer group in coordinator to share functionality with share group Key: KAFKA-16822 URL: https://issues.apache.org/jira/browse/KAFKA-16822

[jira] [Created] (KAFKA-16755) Implement lock timeout functionality in SharePartition

2024-05-13 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-16755: - Summary: Implement lock timeout functionality in SharePartition Key: KAFKA-16755 URL: https://issues.apache.org/jira/browse/KAFKA-16755 Project: Kafka

[jira] [Created] (KAFKA-16756) Implement max delivery count functionality in SharePartition

2024-05-13 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-16756: - Summary: Implement max delivery count functionality in SharePartition Key: KAFKA-16756 URL: https://issues.apache.org/jira/browse/KAFKA-16756 Project: Kafka

[jira] [Created] (KAFKA-16754) Implement release acquired records functionality in SharePartition

2024-05-13 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-16754: - Summary: Implement release acquired records functionality in SharePartition Key: KAFKA-16754 URL: https://issues.apache.org/jira/browse/KAFKA-16754 Project: Kafka

[jira] [Created] (KAFKA-16753) Implement acknowledge functionality in SharePartition

2024-05-13 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-16753: - Summary: Implement acknowledge functionality in SharePartition Key: KAFKA-16753 URL: https://issues.apache.org/jira/browse/KAFKA-16753 Project: Kafka

[jira] [Created] (KAFKA-16752) Implement acquire functionality in SharePartition

2024-05-13 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-16752: - Summary: Implement acquire functionality in SharePartition Key: KAFKA-16752 URL: https://issues.apache.org/jira/browse/KAFKA-16752 Project: Kafka Issue

[jira] [Created] (KAFKA-16749) Implement share fetch messages

2024-05-13 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-16749: - Summary: Implement share fetch messages Key: KAFKA-16749 URL: https://issues.apache.org/jira/browse/KAFKA-16749 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-16751) Implement release acquired records in SharePartitionManager

2024-05-13 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-16751: - Summary: Implement release acquired records in SharePartitionManager Key: KAFKA-16751 URL: https://issues.apache.org/jira/browse/KAFKA-16751 Project: Kafka

[jira] [Created] (KAFKA-16750) Implement acknowledge API in SharePartitionManager

2024-05-13 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-16750: - Summary: Implement acknowledge API in SharePartitionManager Key: KAFKA-16750 URL: https://issues.apache.org/jira/browse/KAFKA-16750 Project: Kafka Issue

[jira] [Created] (KAFKA-16747) Implement share sessions and context

2024-05-13 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-16747: - Summary: Implement share sessions and context Key: KAFKA-16747 URL: https://issues.apache.org/jira/browse/KAFKA-16747 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-16748) Implement share response handling in SharePartitionManager

2024-05-13 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-16748: - Summary: Implement share response handling in SharePartitionManager Key: KAFKA-16748 URL: https://issues.apache.org/jira/browse/KAFKA-16748 Project: Kafka

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

2024-05-13 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-16746: - Summary: Add support for share acknowledgement request in KafkaApis Key: KAFKA-16746 URL: https://issues.apache.org/jira/browse/KAFKA-16746 Project: Kafka

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

2024-05-13 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-16745: - Summary: Add support for share fetch request in KafkaApis Key: KAFKA-16745 URL: https://issues.apache.org/jira/browse/KAFKA-16745 Project: Kafka Issue

[jira] [Created] (KAFKA-16744) Add support for share group describe in KafkaApis

2024-05-13 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-16744: - Summary: Add support for share group describe in KafkaApis Key: KAFKA-16744 URL: https://issues.apache.org/jira/browse/KAFKA-16744 Project: Kafka Issue

[jira] [Created] (KAFKA-16743) Add support for share group heartbeat in KafkaApis

2024-05-13 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-16743: - Summary: Add support for share group heartbeat in KafkaApis Key: KAFKA-16743 URL: https://issues.apache.org/jira/browse/KAFKA-16743 Project: Kafka Issue

[jira] [Created] (KAFKA-16741) Add SharGroupHeartbeat API support in GroupCoordinator

2024-05-13 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-16741: - Summary: Add SharGroupHeartbeat API support in GroupCoordinator Key: KAFKA-16741 URL: https://issues.apache.org/jira/browse/KAFKA-16741 Project: Kafka

[jira] [Created] (KAFKA-16742) Add ShareGroupDescribe API support in GroupCoordinator

2024-05-13 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-16742: - Summary: Add ShareGroupDescribe API support in GroupCoordinator Key: KAFKA-16742 URL: https://issues.apache.org/jira/browse/KAFKA-16742 Project: Kafka

[jira] [Created] (KAFKA-16740) Define skeleton for SharePartitionManager and SharePartition

2024-05-13 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-16740: - Summary: Define skeleton for SharePartitionManager and SharePartition Key: KAFKA-16740 URL: https://issues.apache.org/jira/browse/KAFKA-16740 Project: Kafka

[jira] [Created] (KAFKA-16492) Flaky test: testAlterSinkConnectorOffsetsDifferentKafkaClusterTargeted – org.apache.kafka.connect.integration.OffsetsApiIntegrationTest

2024-04-09 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-16492: - Summary: Flaky test: testAlterSinkConnectorOffsetsDifferentKafkaClusterTargeted – org.apache.kafka.connect.integration.OffsetsApiIntegrationTest Key: KAFKA-16492 URL: https

[jira] [Created] (KAFKA-16491) Flaky test: randomClusterPerturbationsShouldConverge[rackAwareStrategy=balance_subtopology] – org.apache.kafka.streams.processor.internals.assignment.TaskAssignorConverg

2024-04-09 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-16491: - Summary: Flaky test: randomClusterPerturbationsShouldConverge[rackAwareStrategy=balance_subtopology] – org.apache.kafka.streams.processor.internals.assignment.TaskAssignorConvergenceTest Key

[jira] [Created] (KAFKA-16486) Integrate metric measurability changes in metrics collector

2024-04-08 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-16486: - Summary: Integrate metric measurability changes in metrics collector Key: KAFKA-16486 URL: https://issues.apache.org/jira/browse/KAFKA-16486 Project: Kafka

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

2024-04-08 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-16485: - Summary: Fix broker metrics to follow kebab/hyphen case Key: KAFKA-16485 URL: https://issues.apache.org/jira/browse/KAFKA-16485 Project: Kafka Issue Type

Re: [ANNOUNCE] New committer: Christo Lolov

2024-03-26 Thread Apoorv Mittal
Congrats Christo! Regards, Apoorv Mittal +44 7721681581 On Tue, Mar 26, 2024 at 12:05 PM Luke Chen wrote: > Hi, Everyone, > > The PMC of Apache Kafka is pleased to announce a new Kafka committer: > Christo Lolov. > > Christo has been a Kafka contributor since 2021. H

Re: [VOTE] KIP-932: Queues for Kafka

2024-03-18 Thread Apoorv Mittal
Hi Andrew, Thanks for writing the KIP. This is indeed going to be a valuable addition to the Kafka, excited to see the KIP. + 1 (Non-Binding) Regards, Apoorv Mittal +44 7721681581 On Sun, Mar 17, 2024 at 11:16 PM Andrew Schofield < andrew_schofield_j...@outlook.com> wrote: > Hi, &g

Re: [kafka-clients] Re: [ANNOUNCE] Apache Kafka 3.7.0

2024-02-28 Thread Apoorv Mittal
Thanks Stansilav for running the release. That must be exhausting but you executed it well. Regards, Apoorv Mittal +44 7721681581 On Wed, Feb 28, 2024 at 11:22 AM Divij Vaidya wrote: > Thank you Stanislav for running the release, especially fixing the whole > mess with out of sync sit

Re: [VOTE] KIP-1019: Expose method to determine Metric Measurability

2024-02-22 Thread Apoorv Mittal
Thanks everyone for reviewing and voting. The voting for this KIP is now complete. +4 binding (Manikumar, Matthias, Jun, Jason) +1 non-binding (Andrew) Regards, Apoorv Mittal +44 7721681581 On Wed, Feb 21, 2024 at 9:22 PM Jason Gustafson wrote: > +1 Thanks for the KIP! > > On We

Re: [Discuss] KIP-1019: Expose method to determine Metric Measurability

2024-02-21 Thread Apoorv Mittal
or Measurable and Gauge hence went ahead only exposing what is currently needed. Regards, Apoorv Mittal +44 7721681581 On Tue, Feb 20, 2024 at 10:58 PM Jun Rao wrote: > Hi, Apoorv, > > Thanks for the KIP. > > Could we document how we plan to use the new isMeasurable() method? For >

[VOTE] KIP-1019: Expose method to determine Metric Measurability

2024-02-19 Thread Apoorv Mittal
Hi, I’d like to start the voting for KIP-1019: Expose method to determine Metric Measurability. https://cwiki.apache.org/confluence/display/KAFKA/KIP-1019%3A+Expose+method+to+determine+Metric+Measurability Regards, Apoorv Mittal

[jira] [Created] (KAFKA-16280) Expose method to determine Metric Measurability

2024-02-19 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-16280: - Summary: Expose method to determine Metric Measurability Key: KAFKA-16280 URL: https://issues.apache.org/jira/browse/KAFKA-16280 Project: Kafka Issue Type

[Discuss] KIP-1019: Expose method to determine Metric Measurability

2024-02-14 Thread Apoorv Mittal
egards, Apoorv Mittal

[jira] [Resolved] (KAFKA-15683) Delete subscription from metadata when all configs are deleted

2024-01-23 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-15683. --- Resolution: Not A Problem Closing ticket as this is not required, it works as per the

[jira] [Created] (KAFKA-16187) Flaky test: testTopicPatternArg - org.apache.kafka.tools.GetOffsetShellTest

2024-01-23 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-16187: - Summary: Flaky test: testTopicPatternArg - org.apache.kafka.tools.GetOffsetShellTest Key: KAFKA-16187 URL: https://issues.apache.org/jira/browse/KAFKA-16187

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

2024-01-23 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-16186: - Summary: Implement broker metrics for client telemetry usage Key: KAFKA-16186 URL: https://issues.apache.org/jira/browse/KAFKA-16186 Project: Kafka Issue

[jira] [Created] (KAFKA-16177) Flaky test: testBatchSizeZeroNoPartitionNoRecordKey – kafka.api.PlaintextProducerSendTest

2024-01-19 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-16177: - Summary: Flaky test: testBatchSizeZeroNoPartitionNoRecordKey – kafka.api.PlaintextProducerSendTest Key: KAFKA-16177 URL: https://issues.apache.org/jira/browse/KAFKA-16177

[jira] [Created] (KAFKA-16176) Flaky test: testSendToPartitionWithFollowerShutdownShouldNotTimeout – kafka.api.PlaintextProducerSendTest

2024-01-19 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-16176: - Summary: Flaky test: testSendToPartitionWithFollowerShutdownShouldNotTimeout – kafka.api.PlaintextProducerSendTest Key: KAFKA-16176 URL: https://issues.apache.org/jira/browse

[jira] [Created] (KAFKA-16175) Flaky test: testAsynchronousAuthorizerAclUpdatesDontBlockRequestThreads – kafka.api.SslAdminIntegrationTest

2024-01-19 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-16175: - Summary: Flaky test: testAsynchronousAuthorizerAclUpdatesDontBlockRequestThreads – kafka.api.SslAdminIntegrationTest Key: KAFKA-16175 URL: https://issues.apache.org/jira

[jira] [Created] (KAFKA-16174) Flaky test: testDescribeQuorumStatusSuccessful – org.apache.kafka.tools.MetadataQuorumCommandTest

2024-01-19 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-16174: - Summary: Flaky test: testDescribeQuorumStatusSuccessful – org.apache.kafka.tools.MetadataQuorumCommandTest Key: KAFKA-16174 URL: https://issues.apache.org/jira/browse/KAFKA

[jira] [Created] (KAFKA-16173) Flaky test: testTimeoutMetrics – org.apache.kafka.controller.QuorumControllerMetricsIntegrationTest

2024-01-19 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-16173: - Summary: Flaky test: testTimeoutMetrics – org.apache.kafka.controller.QuorumControllerMetricsIntegrationTest Key: KAFKA-16173 URL: https://issues.apache.org/jira/browse/KAFKA

  1   2   >