[jira] [Created] (KAFKA-18653) Fix mocks and potential thread leak issues causing silent RejectedExecutionException

2025-01-27 Thread Abhinav Dixit (Jira)
Abhinav Dixit created KAFKA-18653: - Summary: Fix mocks and potential thread leak issues causing silent RejectedExecutionException Key: KAFKA-18653 URL: https://issues.apache.org/jira/browse/KAFKA-18653

[jira] [Created] (KAFKA-18468) Write share consumer performance tests

2025-01-09 Thread Abhinav Dixit (Jira)
Abhinav Dixit created KAFKA-18468: - Summary: Write share consumer performance tests Key: KAFKA-18468 URL: https://issues.apache.org/jira/browse/KAFKA-18468 Project: Kafka Issue Type: Sub

[jira] [Resolved] (KAFKA-18428) Measure share consumers performance

2025-01-08 Thread Abhinav Dixit (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abhinav Dixit resolved KAFKA-18428. --- Resolution: Fixed > Measure share consumers performa

[jira] [Created] (KAFKA-18428) Measure share consumers performance

2025-01-07 Thread Abhinav Dixit (Jira)
Abhinav Dixit created KAFKA-18428: - Summary: Measure share consumers performance Key: KAFKA-18428 URL: https://issues.apache.org/jira/browse/KAFKA-18428 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-18404) Remove partitionMaxBytes from DelayedShareFetch

2025-01-05 Thread Abhinav Dixit (Jira)
Abhinav Dixit created KAFKA-18404: - Summary: Remove partitionMaxBytes from DelayedShareFetch Key: KAFKA-18404 URL: https://issues.apache.org/jira/browse/KAFKA-18404 Project: Kafka Issue

[jira] [Resolved] (KAFKA-18018) Consumption degrading when using DefaultStatePersister for 1 million records of size 1KB

2024-12-16 Thread Abhinav Dixit (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abhinav Dixit resolved KAFKA-18018. --- Resolution: Later > Consumption degrading when using DefaultStatePersister for 1 mill

[jira] [Created] (KAFKA-18265) Optimizing SharePartition locking to improve fetch speed

2024-12-16 Thread Abhinav Dixit (Jira)
Abhinav Dixit created KAFKA-18265: - Summary: Optimizing SharePartition locking to improve fetch speed Key: KAFKA-18265 URL: https://issues.apache.org/jira/browse/KAFKA-18265 Project: Kafka

[jira] [Created] (KAFKA-18148) the persister methods deleteState, initializeState, and readSummary should not declare exceptions in their method signatures

2024-12-03 Thread Abhinav Dixit (Jira)
Abhinav Dixit created KAFKA-18148: - Summary: the persister methods deleteState, initializeState, and readSummary should not declare exceptions in their method signatures Key: KAFKA-18148 URL: https

Re: [ANNOUNCE] New committer: Andrew Schofield

2024-12-02 Thread Abhinav Dixit
Congratulations Andrew. Very happy for you :) On Mon, Dec 2, 2024 at 7:52 PM TengYao Chi wrote: > Congratulations Andrew > Very well deserved. > > > Mayank Shekhar Narula 於 2024年12月2日 週一 > 下午10:18寫道: > > > Congratulations Andrew. > > >

[jira] [Created] (KAFKA-18129) `SharePartition#maybeInitialize` doesn't obtain write lock to complete the initialization post persister read

2024-12-01 Thread Abhinav Dixit (Jira)
Abhinav Dixit created KAFKA-18129: - Summary: `SharePartition#maybeInitialize` doesn't obtain write lock to complete the initialization post persister read Key: KAFKA-18129 URL: https://issues.apache.org

[jira] [Resolved] (KAFKA-18043) Fix flaky test - StreamThreadTest: shouldLogAndRecordSkippedRecordsForInvalidTimestamps

2024-11-19 Thread Abhinav Dixit (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abhinav Dixit resolved KAFKA-18043. --- Resolution: Duplicate Duplicate with Jira https://issues.apache.org/jira/browse/KAFKA-18038

[jira] [Created] (KAFKA-18043) Fix flaky test - StreamThreadTest: shouldLogAndRecordSkippedRecordsForInvalidTimestamps

2024-11-19 Thread Abhinav Dixit (Jira)
Abhinav Dixit created KAFKA-18043: - Summary: Fix flaky test - StreamThreadTest: shouldLogAndRecordSkippedRecordsForInvalidTimestamps Key: KAFKA-18043 URL: https://issues.apache.org/jira/browse/KAFKA-18043

[jira] [Created] (KAFKA-18027) MINOR: Correct DelayedOperationPurgatory comment about operation completion

2024-11-16 Thread Abhinav Dixit (Jira)
Abhinav Dixit created KAFKA-18027: - Summary: MINOR: Correct DelayedOperationPurgatory comment about operation completion Key: KAFKA-18027 URL: https://issues.apache.org/jira/browse/KAFKA-18027

[jira] [Created] (KAFKA-18022) minBytes implementation for uncommon cases

2024-11-14 Thread Abhinav Dixit (Jira)
Abhinav Dixit created KAFKA-18022: - Summary: minBytes implementation for uncommon cases Key: KAFKA-18022 URL: https://issues.apache.org/jira/browse/KAFKA-18022 Project: Kafka Issue Type: Sub

[jira] [Created] (KAFKA-18018) Consumption failing with DefaultStatePersister for 1 million records

2024-11-14 Thread Abhinav Dixit (Jira)
Abhinav Dixit created KAFKA-18018: - Summary: Consumption failing with DefaultStatePersister for 1 million records Key: KAFKA-18018 URL: https://issues.apache.org/jira/browse/KAFKA-18018 Project

[jira] [Resolved] (KAFKA-17957) Console share consumer unable to consume all messages when using multiple brokers

2024-11-13 Thread Abhinav Dixit (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abhinav Dixit resolved KAFKA-17957. --- Resolution: Invalid > Console share consumer unable to consume all messages when us

[jira] [Resolved] (KAFKA-17829) Verify ShareFetch requests return a completed/erroneous future on purgatory close

2024-11-13 Thread Abhinav Dixit (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abhinav Dixit resolved KAFKA-17829. --- Resolution: Not A Bug > Verify ShareFetch requests return a completed/erroneous future

[jira] [Created] (KAFKA-17957) Console share consumer unable to consume all messages when using multiple brokers

2024-11-07 Thread Abhinav Dixit (Jira)
Abhinav Dixit created KAFKA-17957: - Summary: Console share consumer unable to consume all messages when using multiple brokers Key: KAFKA-17957 URL: https://issues.apache.org/jira/browse/KAFKA-17957

[jira] [Created] (KAFKA-17948) Potential problem during tryComplete and onComplete simultaneous calls

2024-11-05 Thread Abhinav Dixit (Jira)
Abhinav Dixit created KAFKA-17948: - Summary: Potential problem during tryComplete and onComplete simultaneous calls Key: KAFKA-17948 URL: https://issues.apache.org/jira/browse/KAFKA-17948 Project

[jira] [Created] (KAFKA-17943) Error handling when calling replicaManager.getPartitionOrException

2024-11-05 Thread Abhinav Dixit (Jira)
Abhinav Dixit created KAFKA-17943: - Summary: Error handling when calling replicaManager.getPartitionOrException Key: KAFKA-17943 URL: https://issues.apache.org/jira/browse/KAFKA-17943 Project: Kafka

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

2024-10-21 Thread Abhinav Dixit (Jira)
Abhinav Dixit created KAFKA-17848: - Summary: Resolve reliability issue on the broker post moving delayed share fetch purgatory to ReplicaManager Key: KAFKA-17848 URL: https://issues.apache.org/jira/browse/KAFKA

[jira] [Created] (KAFKA-17829) Add an integration test verifying ShareFetch requests return a future on purgatory close

2024-10-18 Thread Abhinav Dixit (Jira)
Abhinav Dixit created KAFKA-17829: - Summary: Add an integration test verifying ShareFetch requests return a future on purgatory close Key: KAFKA-17829 URL: https://issues.apache.org/jira/browse/KAFKA-17829

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

2024-10-13 Thread Abhinav Dixit (Jira)
Abhinav Dixit created KAFKA-17783: - Summary: Remove sharePartition from SharePartitionManager if the partition partition is deleted or becomes a follower Key: KAFKA-17783 URL: https://issues.apache.org/jira

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

2024-10-08 Thread Abhinav Dixit (Jira)
Abhinav Dixit created KAFKA-17743: - Summary: Add minBytes implementation to DelayedShareFetch Key: KAFKA-17743 URL: https://issues.apache.org/jira/browse/KAFKA-17743 Project: Kafka Issue

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

2024-10-08 Thread Abhinav Dixit (Jira)
Abhinav Dixit created KAFKA-17742: - Summary: Move DelayedShareFetchPurgatory declaration to ReplicaManager Key: KAFKA-17742 URL: https://issues.apache.org/jira/browse/KAFKA-17742 Project: Kafka

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

2024-10-03 Thread Abhinav Dixit (Jira)
Abhinav Dixit created KAFKA-17703: - Summary: Move DelayedActionsQueue outside DelayedShareFetch Key: KAFKA-17703 URL: https://issues.apache.org/jira/browse/KAFKA-17703 Project: Kafka Issue

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

2024-09-13 Thread Abhinav Dixit (Jira)
Abhinav Dixit created KAFKA-17545: - Summary: Get rid of fetch queue in SharePartitionManager Key: KAFKA-17545 URL: https://issues.apache.org/jira/browse/KAFKA-17545 Project: Kafka Issue Type

[jira] [Resolved] (KAFKA-17401) Add config for purge interval for Share Fetch Purgatory

2024-09-11 Thread Abhinav Dixit (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abhinav Dixit resolved KAFKA-17401. --- Fix Version/s: 4.0.0 Resolution: Fixed > Add config for purge interval for Sh

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

2024-09-11 Thread Abhinav Dixit (Jira)
Abhinav Dixit created KAFKA-17522: - Summary: Share partition acquire() need not return a future Key: KAFKA-17522 URL: https://issues.apache.org/jira/browse/KAFKA-17522 Project: Kafka Issue

[jira] [Created] (KAFKA-17447) Changed fetch queue processing to reduce the no. of locking and unlocking activity

2024-08-30 Thread Abhinav Dixit (Jira)
Abhinav Dixit created KAFKA-17447: - Summary: Changed fetch queue processing to reduce the no. of locking and unlocking activity Key: KAFKA-17447 URL: https://issues.apache.org/jira/browse/KAFKA-17447

[jira] [Created] (KAFKA-17401) Add config for purge interval for Share Fetch Purgatory

2024-08-22 Thread Abhinav Dixit (Jira)
Abhinav Dixit created KAFKA-17401: - Summary: Add config for purge interval for Share Fetch Purgatory Key: KAFKA-17401 URL: https://issues.apache.org/jira/browse/KAFKA-17401 Project: Kafka

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

2024-08-22 Thread Abhinav Dixit (Jira)
Abhinav Dixit created KAFKA-17400: - Summary: Intorduce a purgatory to deal with share fetch requests that cannot be completed instantaneously Key: KAFKA-17400 URL: https://issues.apache.org/jira/browse/KAFKA

[jira] [Resolved] (KAFKA-17210) Broker fixes for smooth concurrent fetches on share partition

2024-07-30 Thread Abhinav Dixit (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abhinav Dixit resolved KAFKA-17210. --- Fix Version/s: 4.0.0 Resolution: Fixed > Broker fixes for smooth concurrent fetc

[jira] [Created] (KAFKA-17210) Broker fixes for smooth concurrent fetches on share partition

2024-07-28 Thread Abhinav Dixit (Jira)
Abhinav Dixit created KAFKA-17210: - Summary: Broker fixes for smooth concurrent fetches on share partition Key: KAFKA-17210 URL: https://issues.apache.org/jira/browse/KAFKA-17210 Project: Kafka

[jira] [Resolved] (KAFKA-17071) SharePartition - Add more unit tests

2024-07-08 Thread Abhinav Dixit (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abhinav Dixit resolved KAFKA-17071. --- Fix Version/s: 4.0.0 3.9.0 Resolution: Fixed > SharePartit

[jira] [Created] (KAFKA-17071) SharePartition - Add more unit tests

2024-07-03 Thread Abhinav Dixit (Jira)
Abhinav Dixit created KAFKA-17071: - Summary: SharePartition - Add more unit tests Key: KAFKA-17071 URL: https://issues.apache.org/jira/browse/KAFKA-17071 Project: Kafka Issue Type: Sub-task

[jira] [Resolved] (KAFKA-17026) Implement updateCacheAndOffsets functionality on LSO movement

2024-07-03 Thread Abhinav Dixit (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abhinav Dixit resolved KAFKA-17026. --- Fix Version/s: 4.0.0 3.9.0 Resolution: Fixed > Implem

[jira] [Resolved] (KAFKA-15727) KRaft support in AlterUserScramCredentialsRequestNotAuthorizedTest

2024-07-02 Thread Abhinav Dixit (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abhinav Dixit resolved KAFKA-15727. --- Resolution: Fixed > KRaft support in AlterUserScramCredentialsRequestNotAuthorizedT

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

2024-06-27 Thread Abhinav Dixit (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abhinav Dixit resolved KAFKA-16754. --- Fix Version/s: 4.0.0 3.9.0 Resolution: Fixed > Implement rele

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

2024-06-26 Thread Abhinav Dixit (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abhinav Dixit resolved KAFKA-16751. --- Fix Version/s: 4.0.0 3.9.0 Resolution: Fixed > Implement rele

[jira] [Resolved] (KAFKA-17003) Implement SharePartitionManager close functionality

2024-06-26 Thread Abhinav Dixit (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abhinav Dixit resolved KAFKA-17003. --- Fix Version/s: 4.0.0 3.9.0 Resolution: Fixed > Implem

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

2024-06-25 Thread Abhinav Dixit (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abhinav Dixit resolved KAFKA-16755. --- Fix Version/s: 4.0.0 3.9.0 Resolution: Fixed > Implement l

[jira] [Resolved] (KAFKA-17004) MINOR: Remove extra synchronized blocks in SharePartitionManager

2024-06-24 Thread Abhinav Dixit (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abhinav Dixit resolved KAFKA-17004. --- Fix Version/s: 4.0.0 3.9.0 Resolution: Fixed > MINOR: Rem

[jira] [Created] (KAFKA-17026) Implement updateCachedAndOffsets functionality on LSO movement

2024-06-24 Thread Abhinav Dixit (Jira)
Abhinav Dixit created KAFKA-17026: - Summary: Implement updateCachedAndOffsets functionality on LSO movement Key: KAFKA-17026 URL: https://issues.apache.org/jira/browse/KAFKA-17026 Project: Kafka

[jira] [Created] (KAFKA-17004) MINOR: Remove extra synchronized blocks in SharePartitionManager

2024-06-20 Thread Abhinav Dixit (Jira)
Abhinav Dixit created KAFKA-17004: - Summary: MINOR: Remove extra synchronized blocks in SharePartitionManager Key: KAFKA-17004 URL: https://issues.apache.org/jira/browse/KAFKA-17004 Project: Kafka

[jira] [Created] (KAFKA-17003) Implement SharePartitionManager close functionality

2024-06-20 Thread Abhinav Dixit (Jira)
Abhinav Dixit created KAFKA-17003: - Summary: Implement SharePartitionManager close functionality Key: KAFKA-17003 URL: https://issues.apache.org/jira/browse/KAFKA-17003 Project: Kafka Issue

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

2024-06-14 Thread Abhinav Dixit (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abhinav Dixit resolved KAFKA-16747. --- Resolution: Fixed > Implement share sessions and cont

[jira] [Resolved] (KAFKA-16914) Add Share Group dynamic and broker configs

2024-06-11 Thread Abhinav Dixit (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abhinav Dixit resolved KAFKA-16914. --- Resolution: Fixed > Add Share Group dynamic and broker conf

Re: Requesting permissions to contribute to Apache Kafka

2024-01-08 Thread Abhinav Dixit
Thanks Josep. On Mon, Jan 8, 2024 at 7:38 PM Josep Prat wrote: > Hi Abhinav, > > This one I could find :) > > You are now all set! Happy contributing! > > Best, > > On Mon, Jan 8, 2024 at 2:39 PM Abhinav Dixit > wrote: > > > Hi Josep, > > Thanks

Re: Requesting permissions to contribute to Apache Kafka

2024-01-08 Thread Abhinav Dixit
r Wiki ID > in the system. Can you confirm you created it and named it > "adixitconfluent"? > > Best, > > On Mon, Jan 8, 2024 at 2:10 PM Abhinav Dixit > wrote: > > > Hi Team, > > I am writing this email to request permissions to contribute to Apache &g

Requesting permissions to contribute to Apache Kafka

2024-01-08 Thread Abhinav Dixit
Hi Team, I am writing this email to request permissions to contribute to Apache Kafka. Here are my details - JIRA ID - adixitconfluent WIKI ID - adixitconfluent Please let me know if anything is missing. Thanks, Abhinav