Abhinav Dixit created KAFKA-19502:
-
Summary: During write state call processing,a batch can be split
into offsets which is not accounted for
Key: KAFKA-19502
URL: https://issues.apache.org/jira/browse/KAFKA-19502
Abhinav Dixit created KAFKA-19476:
-
Summary: Improve state transition handling in SharePartition
Key: KAFKA-19476
URL: https://issues.apache.org/jira/browse/KAFKA-19476
Project: Kafka
Issue T
Abhinav Dixit created KAFKA-19464:
-
Summary: remove findNextFetchOffset.set(true) from acknowledge and
release acquired records functionality
Key: KAFKA-19464
URL: https://issues.apache.org/jira/browse/KAFKA-19464
Abhinav Dixit created KAFKA-19463:
-
Summary: nextFetchOffset does not take ongoing state transition
into account
Key: KAFKA-19463
URL: https://issues.apache.org/jira/browse/KAFKA-19463
Project: Kafka
Abhinav Dixit created KAFKA-19450:
-
Summary: ShareConsumerPerformance does not handle exceptions from
consumeMessagesForSingleShareConsumer
Key: KAFKA-19450
URL: https://issues.apache.org/jira/browse/KAFKA-19450
Abhinav Dixit created KAFKA-19345:
-
Summary: Use ShareFetchUtils mock for DelayedShareFetchTest tests
Key: KAFKA-19345
URL: https://issues.apache.org/jira/browse/KAFKA-19345
Project: Kafka
Is
[
https://issues.apache.org/jira/browse/KAFKA-19266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Abhinav Dixit resolved KAFKA-19266.
---
Resolution: Not A Problem
> Eliminate flakiness in test
> SharePartitionTest.testAcquisitio
Abhinav Dixit created KAFKA-19328:
-
Summary: SharePartitionManagerTest
testMultipleConcurrentShareFetches doAnswer chaining needs verification
Key: KAFKA-19328
URL: https://issues.apache.org/jira/browse/KAFKA-1932
Abhinav Dixit created KAFKA-19310:
-
Summary: Missing mocks for DelayedShareFetchTest tests related to
Memory Records slicing
Key: KAFKA-19310
URL: https://issues.apache.org/jira/browse/KAFKA-19310
Pro
Abhinav Dixit created KAFKA-19291:
-
Summary: Increase the timeout of remote storage share fetch
requests in purgatory
Key: KAFKA-19291
URL: https://issues.apache.org/jira/browse/KAFKA-19291
Project: K
Abhinav Dixit created KAFKA-19268:
-
Summary: Missing mocks for SharePartitionManagerTest tests
Key: KAFKA-19268
URL: https://issues.apache.org/jira/browse/KAFKA-19268
Project: Kafka
Issue Typ
Abhinav Dixit created KAFKA-19266:
-
Summary: Eliminate flakiness in test
SharePartitionTest.testAcquisitionLockTimeoutForBatchesPostStartOffsetMovement
Key: KAFKA-19266
URL: https://issues.apache.org/jira/browse/K
Abhinav Dixit created KAFKA-19253:
-
Summary: Implement CCloud metadata version handling correctly for
enabling QfK feature
Key: KAFKA-19253
URL: https://issues.apache.org/jira/browse/KAFKA-19253
Proje
[
https://issues.apache.org/jira/browse/KAFKA-18796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Abhinav Dixit resolved KAFKA-18796.
---
Fix Version/s: 4.1.0
Resolution: Fixed
> Fix flaky test testAcquisitionLockOnOffsetWi
Abhinav Dixit created KAFKA-19215:
-
Summary: Handle share partition fetch lock cleanly in
DelayedShareFetch to avoid a member incorrectly releasing a share partition's
fetch lock
Key: KAFKA-19215
URL: https://iss
Abhinav Dixit created KAFKA-19187:
-
Summary: MINOR: Disallow raw types and fail build for test files
Key: KAFKA-19187
URL: https://issues.apache.org/jira/browse/KAFKA-19187
Project: Kafka
Iss
Abhinav Dixit created KAFKA-19133:
-
Summary: Support fetching for multiple remote fetch topic
partitions in a single share fetch request
Key: KAFKA-19133
URL: https://issues.apache.org/jira/browse/KAFKA-19133
[
https://issues.apache.org/jira/browse/KAFKA-19085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Abhinav Dixit resolved KAFKA-19085.
---
Fix Version/s: 4.1.0
Resolution: Fixed
> SharePartitionManagerTest testMultipleConcur
Abhinav Dixit created KAFKA-19085:
-
Summary: SharePartitionManagerTest
testMultipleConcurrentShareFetches throws silent exception and works incorrectly
Key: KAFKA-19085
URL: https://issues.apache.org/jira/browse/K
[
https://issues.apache.org/jira/browse/KAFKA-18932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Abhinav Dixit resolved KAFKA-18932.
---
Fix Version/s: 4.1.0
Resolution: Fixed
> Remove partition max bytes usage from share
[
https://issues.apache.org/jira/browse/KAFKA-18788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Abhinav Dixit resolved KAFKA-18788.
---
Resolution: Duplicate
> Improve simple assignor by having a max no. of partitions limit and
Abhinav Dixit created KAFKA-18932:
-
Summary: Remove partitionMaxBytes usage from brokers for share
fetch requests
Key: KAFKA-18932
URL: https://issues.apache.org/jira/browse/KAFKA-18932
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-18757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Abhinav Dixit resolved KAFKA-18757.
---
Fix Version/s: 4.1.0
Resolution: Fixed
> Create full-function SimpleAssignor to match
[
https://issues.apache.org/jira/browse/KAFKA-18796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Abhinav Dixit reopened KAFKA-18796:
---
> Fix flaky test testAcquisitionLockOnOffsetWithWriteShareGroupStateFailure
> --
[
https://issues.apache.org/jira/browse/KAFKA-18796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Abhinav Dixit resolved KAFKA-18796.
---
Resolution: Not A Problem
> Fix flaky test testAcquisitionLockOnOffsetWithWriteShareGroupSta
Abhinav Dixit created KAFKA-18796:
-
Summary: Fix flaky test
testAcquistioLockOnOffsetWithWriteShareGroupStateFailure
Key: KAFKA-18796
URL: https://issues.apache.org/jira/browse/KAFKA-18796
Project: Ka
Abhinav Dixit created KAFKA-18788:
-
Summary: Improve simple assignor by having a max no. of partitions
limit and min no. of partitions threshold assignment to members
Key: KAFKA-18788
URL: https://issues.apache.or
Abhinav Dixit created KAFKA-18757:
-
Summary: Create full-function SimpleAssignor to match KIP-932
description
Key: KAFKA-18757
URL: https://issues.apache.org/jira/browse/KAFKA-18757
Project: Kafka
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
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-task
[
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 performance
> --
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
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 Type
[
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 million rec
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
Is
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://issues.apach
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/brows
[
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
Abhinav Dixit created KAFKA-18043:
-
Summary: Fix flaky test - StreamThreadTest:
shouldLogAndRecordSkippedRecordsForInvalidTimestamps
Key: KAFKA-18043
URL: https://issues.apache.org/jira/browse/KAFKA-18043
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
Project
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-
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: Kafka
[
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 using multi
[
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 on pu
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
P
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: Kaf
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
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-17
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
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/browse
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 Type
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
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 Ty
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:
[
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 Share Fetc
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 Ty
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
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
Iss
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-17400
[
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 fetches o
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
[
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
> SharePartition - Ad
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
[
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
> Implement updateCac
[
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 AlterUserScramCredentialsRequestNotAuthorizedTest
> ---
[
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 release a
[
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 release a
[
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
> Implement SharePart
[
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 lock time
[
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: Remove extra
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
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
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 T
[
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 context
> -
[
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 configs
> ---
75 matches
Mail list logo
