Lianet Magrans created KAFKA-16823:
--
Summary: Extract LegacyConsumer-specific unit tests from generic
KafkaConsumerTest
Key: KAFKA-16823
URL: https://issues.apache.org/jira/browse/KAFKA-16823
Lianet Magrans created KAFKA-16816:
--
Summary: Remove unneeded FencedInstanceId support on commit path
for new consumer
Key: KAFKA-16816
URL: https://issues.apache.org/jira/browse/KAFKA-16816
Lianet Magrans created KAFKA-16815:
--
Summary: Handle FencedInstanceId on heartbeat for new consumer
Key: KAFKA-16815
URL: https://issues.apache.org/jira/browse/KAFKA-16815
Project: Kafka
Lianet Magrans created KAFKA-16792:
--
Summary: Enable related unit tests that fail only for new consumer
with to poll(0)
Key: KAFKA-16792
URL: https://issues.apache.org/jira/browse/KAFKA-16792
Lianet Magrans created KAFKA-16786:
--
Summary: New consumer subscribe should not require the deprecated
partition.assignment.strategy
Key: KAFKA-16786
URL: https://issues.apache.org/jira/browse/KAFKA-16786
Lianet Magrans created KAFKA-16777:
--
Summary: New consumer should throw NoOffsetForPartitionException
on continuous poll zero if no reset strategy
Key: KAFKA-16777
URL:
Lianet Magrans created KAFKA-16766:
--
Summary: New consumer offsetsForTimes timeout exception does not
have the proper message
Key: KAFKA-16766
URL: https://issues.apache.org/jira/browse/KAFKA-16766
Lianet Magrans created KAFKA-16764:
--
Summary: New consumer should throw InvalidTopicException on poll
when invalid topic in metadata
Key: KAFKA-16764
URL: https://issues.apache.org/jira/browse/KAFKA-16764
[
https://issues.apache.org/jira/browse/KAFKA-16406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans resolved KAFKA-16406.
Resolution: Fixed
> Split long-running consumer integration test
>
Lianet Magrans created KAFKA-16737:
--
Summary: Clean up KafkaConsumerTest TODOs enabling tests for new
consumer
Key: KAFKA-16737
URL: https://issues.apache.org/jira/browse/KAFKA-16737
Project: Kafka
Lianet Magrans created KAFKA-16695:
--
Summary: Improve expired poll interval logging by showing exceeded
time
Key: KAFKA-16695
URL: https://issues.apache.org/jira/browse/KAFKA-16695
Project: Kafka
Lianet Magrans created KAFKA-16675:
--
Summary: Move rebalance callback test for positions to callbacks
test file
Key: KAFKA-16675
URL: https://issues.apache.org/jira/browse/KAFKA-16675
Project: Kafka
Lianet Magrans created KAFKA-16665:
--
Summary: Fail to get partition's position from within
onPartitionsAssigned callback in new consumer
Key: KAFKA-16665
URL: https://issues.apache.org/jira/browse/KAFKA-16665
Lianet Magrans created KAFKA-16628:
--
Summary: Add system test for validating static consumer bounce and
assignment when not eager
Key: KAFKA-16628
URL: https://issues.apache.org/jira/browse/KAFKA-16628
Lianet Magrans created KAFKA-16566:
--
Summary: Update static membership fencing system test to support
new protocol
Key: KAFKA-16566
URL: https://issues.apache.org/jira/browse/KAFKA-16566
Project:
Lianet Magrans created KAFKA-16528:
--
Summary: Reset member heartbeat interval when request sent
Key: KAFKA-16528
URL: https://issues.apache.org/jira/browse/KAFKA-16528
Project: Kafka
Issue
Lianet Magrans created KAFKA-16493:
--
Summary: Avoid unneeded subscription regex check if metadata
version unchanged
Key: KAFKA-16493
URL: https://issues.apache.org/jira/browse/KAFKA-16493
Project:
Lianet Magrans created KAFKA-16418:
--
Summary: Split long-running admin client integration tests
Key: KAFKA-16418
URL: https://issues.apache.org/jira/browse/KAFKA-16418
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-16375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans resolved KAFKA-16375.
Resolution: Fixed
> Fix logic for discarding reconciliation if member rejoined
>
Lianet Magrans created KAFKA-16406:
--
Summary: Split long-running consumer integration test
Key: KAFKA-16406
URL: https://issues.apache.org/jira/browse/KAFKA-16406
Project: Kafka
Issue Type:
Lianet Magrans created KAFKA-16375:
--
Summary: Fix logic for discarding reconciliation if member rejoined
Key: KAFKA-16375
URL: https://issues.apache.org/jira/browse/KAFKA-16375
Project: Kafka
Lianet Magrans created KAFKA-16301:
--
Summary: Review fenced member unsubscribe/subscribe callbacks
interaction
Key: KAFKA-16301
URL: https://issues.apache.org/jira/browse/KAFKA-16301
Project: Kafka
Lianet Magrans created KAFKA-16298:
--
Summary: Ensure user callbacks exceptions are propagated to the
user on consumer poll
Key: KAFKA-16298
URL: https://issues.apache.org/jira/browse/KAFKA-16298
Lianet Magrans created KAFKA-16258:
--
Summary: Stale member should trigger onPartitionsLost when leaving
group
Key: KAFKA-16258
URL: https://issues.apache.org/jira/browse/KAFKA-16258
Project: Kafka
Lianet Magrans created KAFKA-16251:
--
Summary: Fenced member should not send heartbeats while waiting
for onPartitionsLost to complete
Key: KAFKA-16251
URL: https://issues.apache.org/jira/browse/KAFKA-16251
Lianet Magrans created KAFKA-16233:
--
Summary: Review auto-commit continuously committing when no
progress
Key: KAFKA-16233
URL: https://issues.apache.org/jira/browse/KAFKA-16233
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-16133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans resolved KAFKA-16133.
Fix Version/s: 3.7.0
(was: 3.8.0)
Resolution: Fixed
>
Lianet Magrans created KAFKA-16224:
--
Summary: Fix handling of deleted topic when auto-committing before
revocation
Key: KAFKA-16224
URL: https://issues.apache.org/jira/browse/KAFKA-16224
Project:
Lianet Magrans created KAFKA-16215:
--
Summary: Consumer does not rejoin after fenced on delayed
revocation
Key: KAFKA-16215
URL: https://issues.apache.org/jira/browse/KAFKA-16215
Project: Kafka
Lianet Magrans created KAFKA-16203:
--
Summary: AutoCommit of empty offsets blocks following requests due
to inflight flag
Key: KAFKA-16203
URL: https://issues.apache.org/jira/browse/KAFKA-16203
[
https://issues.apache.org/jira/browse/KAFKA-16134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans resolved KAFKA-16134.
Assignee: Lianet Magrans
Resolution: Fixed
Fix merged in
[
https://issues.apache.org/jira/browse/KAFKA-16135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans resolved KAFKA-16135.
Assignee: Lianet Magrans
Resolution: Fixed
Fix merged in
Lianet Magrans created KAFKA-16190:
--
Summary: Member should send full heartbeat when rejoining
Key: KAFKA-16190
URL: https://issues.apache.org/jira/browse/KAFKA-16190
Project: Kafka
Issue
Lianet Magrans created KAFKA-16185:
--
Summary: Fix client reconciliation of same assignment received in
different epochs
Key: KAFKA-16185
URL: https://issues.apache.org/jira/browse/KAFKA-16185
Lianet Magrans created KAFKA-16165:
--
Summary: Consumer invalid transition on expired poll interval
Key: KAFKA-16165
URL: https://issues.apache.org/jira/browse/KAFKA-16165
Project: Kafka
Lianet Magrans created KAFKA-16156:
--
Summary: System test failing on endOffsets with negative timestamps
Key: KAFKA-16156
URL: https://issues.apache.org/jira/browse/KAFKA-16156
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans reopened KAFKA-15538:
> Client support for java regex based subscription
>
[
https://issues.apache.org/jira/browse/KAFKA-15866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans resolved KAFKA-15866.
Fix Version/s: 3.7.0
(was: 3.8.0)
Assignee: (was: Lan
Lianet Magrans created KAFKA-16107:
--
Summary: Ensure consumer does not start fetching from added
partitions until onPartitionsAssgined completes
Key: KAFKA-16107
URL:
[
https://issues.apache.org/jira/browse/KAFKA-15946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans resolved KAFKA-15946.
Fix Version/s: 3.7.0
(was: 3.8.0)
Assignee: Lianet Magrans
[
https://issues.apache.org/jira/browse/KAFKA-15967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans resolved KAFKA-15967.
Fix Version/s: 3.7.0
(was: 3.8.0)
Assignee: Lianet Magrans
[
https://issues.apache.org/jira/browse/KAFKA-15872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans resolved KAFKA-15872.
Fix Version/s: (was: 3.8.0)
Resolution: Duplicate
> Investigate autocommit
[
https://issues.apache.org/jira/browse/KAFKA-15455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans resolved KAFKA-15455.
Fix Version/s: 3.7.0
(was: 3.8.0)
Resolution: Fixed
> Add
[
https://issues.apache.org/jira/browse/KAFKA-16099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans resolved KAFKA-16099.
Fix Version/s: 3.7.0
Resolution: Fixed
> Handle timeouts for
Lianet Magrans created KAFKA-16103:
--
Summary: Review client logic for triggering offset commit callbacks
Key: KAFKA-16103
URL: https://issues.apache.org/jira/browse/KAFKA-16103
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-15846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans resolved KAFKA-15846.
Fix Version/s: (was: 3.8.0)
Resolution: Duplicate
> Review consumer leave
[
https://issues.apache.org/jira/browse/KAFKA-15542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans resolved KAFKA-15542.
Fix Version/s: 3.7.0
(was: 3.8.0)
Resolution: Fixed
Fixed
[
https://issues.apache.org/jira/browse/KAFKA-15515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans resolved KAFKA-15515.
Fix Version/s: (was: 4.0.0)
Resolution: Not A Problem
[
https://issues.apache.org/jira/browse/KAFKA-15325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans resolved KAFKA-15325.
Resolution: Duplicate
> Integrate topicId in OffsetFetch and OffsetCommit async consumer
Lianet Magrans created KAFKA-16033:
--
Summary: Review retry logic of OffsetFetch and OffsetCommit
responses
Key: KAFKA-16033
URL: https://issues.apache.org/jira/browse/KAFKA-16033
Project: Kafka
Lianet Magrans created KAFKA-16032:
--
Summary: Review inconsistent error handling of OffsetFetch and
OffsetCommit responses
Key: KAFKA-16032
URL: https://issues.apache.org/jira/browse/KAFKA-16032
Lianet Magrans created KAFKA-16004:
--
Summary: Review new consumer inflight offset commit logic
Key: KAFKA-16004
URL: https://issues.apache.org/jira/browse/KAFKA-16004
Project: Kafka
Issue
Lianet Magrans created KAFKA-15991:
--
Summary: Flaky new consumer test testGroupIdNotNullAndValid
Key: KAFKA-15991
URL: https://issues.apache.org/jira/browse/KAFKA-15991
Project: Kafka
Issue
Lianet Magrans created KAFKA-15954:
--
Summary: Review minimal effort approach on consumer last heartbeat
on unsubscribe
Key: KAFKA-15954
URL: https://issues.apache.org/jira/browse/KAFKA-15954
Lianet Magrans created KAFKA-15847:
--
Summary: Allow to resolve client metadata for specific topics
Key: KAFKA-15847
URL: https://issues.apache.org/jira/browse/KAFKA-15847
Project: Kafka
Lianet Magrans created KAFKA-15846:
--
Summary: Review consumer leave group request
Key: KAFKA-15846
URL: https://issues.apache.org/jira/browse/KAFKA-15846
Project: Kafka
Issue Type: Sub-task
Lianet Magrans created KAFKA-15843:
--
Summary: Review consumer onPartitionsAssigned called with empty
partitions
Key: KAFKA-15843
URL: https://issues.apache.org/jira/browse/KAFKA-15843
Project: Kafka
Lianet Magrans created KAFKA-15839:
--
Summary: Review topic recreation handling in client reconciliation
Key: KAFKA-15839
URL: https://issues.apache.org/jira/browse/KAFKA-15839
Project: Kafka
Lianet Magrans created KAFKA-15835:
--
Summary: Group commit/callbacks triggering logic
Key: KAFKA-15835
URL: https://issues.apache.org/jira/browse/KAFKA-15835
Project: Kafka
Issue Type:
Lianet Magrans created KAFKA-15832:
--
Summary: Trigger reconciliation based on manager poll
Key: KAFKA-15832
URL: https://issues.apache.org/jira/browse/KAFKA-15832
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-15317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans resolved KAFKA-15317.
Resolution: Fixed
Failing test consistently passing after PR
[
https://issues.apache.org/jira/browse/KAFKA-15539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans resolved KAFKA-15539.
Resolution: Duplicate
> Client should stop fetching while partitions being revoked
>
[
https://issues.apache.org/jira/browse/KAFKA-15573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans resolved KAFKA-15573.
Resolution: Duplicate
> Implement auto-commit on partition assignment revocation
>
Lianet Magrans created KAFKA-15679:
--
Summary: Client support new consumer configs
Key: KAFKA-15679
URL: https://issues.apache.org/jira/browse/KAFKA-15679
Project: Kafka
Issue Type: Sub-task
Lianet Magrans created KAFKA-15631:
--
Summary: Do not send new heartbeat request while another one
in-flight
Key: KAFKA-15631
URL: https://issues.apache.org/jira/browse/KAFKA-15631
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-15540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans resolved KAFKA-15540.
Resolution: Duplicate
Duplicate of KAKFA-15548
> Handle heartbeat and revocation when
Lianet Magrans created KAFKA-15561:
--
Summary: Client support for new SubscriptionPattern based
subscription
Key: KAFKA-15561
URL: https://issues.apache.org/jira/browse/KAFKA-15561
Project: Kafka
Lianet Magrans created KAFKA-15554:
--
Summary: Update client state machine to align with protocol
sending one assignment at a time
Key: KAFKA-15554
URL: https://issues.apache.org/jira/browse/KAFKA-15554
[
https://issues.apache.org/jira/browse/KAFKA-15275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans resolved KAFKA-15275.
Resolution: Fixed
> Implement consumer group membership state machine
>
Lianet Magrans created KAFKA-15550:
--
Summary: OffsetsForTimes validation for negative timestamps in new
consumer
Key: KAFKA-15550
URL: https://issues.apache.org/jira/browse/KAFKA-15550
Project:
Lianet Magrans created KAFKA-15544:
--
Summary: Enable existing client integration tests for new protocol
Key: KAFKA-15544
URL: https://issues.apache.org/jira/browse/KAFKA-15544
Project: Kafka
Lianet Magrans created KAFKA-15543:
--
Summary: Send HB request right after reconciliation completes
Key: KAFKA-15543
URL: https://issues.apache.org/jira/browse/KAFKA-15543
Project: Kafka
Lianet Magrans created KAFKA-15542:
--
Summary: Release member assignments on errors
Key: KAFKA-15542
URL: https://issues.apache.org/jira/browse/KAFKA-15542
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-15438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans resolved KAFKA-15438.
Resolution: Fixed
> Review exception caching logic used for reset/validate positions in
[
https://issues.apache.org/jira/browse/KAFKA-15164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans resolved KAFKA-15164.
Resolution: Fixed
Included in PR https://github.com/apache/kafka/pull/14346
> Extract
Lianet Magrans created KAFKA-15540:
--
Summary: Handle heartbeat and assignment release when consumer
leaves group
Key: KAFKA-15540
URL: https://issues.apache.org/jira/browse/KAFKA-15540
Project:
Lianet Magrans created KAFKA-15539:
--
Summary: Stop fetching while partitions being revoked
Key: KAFKA-15539
URL: https://issues.apache.org/jira/browse/KAFKA-15539
Project: Kafka
Issue Type:
Lianet Magrans created KAFKA-15538:
--
Summary: Resolve regex on client side when using java regex in new
consumer
Key: KAFKA-15538
URL: https://issues.apache.org/jira/browse/KAFKA-15538
Project:
Lianet Magrans created KAFKA-15515:
--
Summary: Remove duplicated integration tests for new consumer
Key: KAFKA-15515
URL: https://issues.apache.org/jira/browse/KAFKA-15515
Project: Kafka
Lianet Magrans created KAFKA-15438:
--
Summary: Review exception caching logic used for reset/validate
positions in async consumer
Key: KAFKA-15438
URL: https://issues.apache.org/jira/browse/KAFKA-15438
Lianet Magrans created KAFKA-15327:
--
Summary: Async consumer should commit offsets on close
Key: KAFKA-15327
URL: https://issues.apache.org/jira/browse/KAFKA-15327
Project: Kafka
Issue
Lianet Magrans created KAFKA-15325:
--
Summary: Integrate topicId in OffsetFetch and OffsetCommit async
consumer calls
Key: KAFKA-15325
URL: https://issues.apache.org/jira/browse/KAFKA-15325
Project:
Lianet Magrans created KAFKA-15317:
--
Summary: Fix for async consumer access to committed offsets with
multiple consumers
Key: KAFKA-15317
URL: https://issues.apache.org/jira/browse/KAFKA-15317
Lianet Magrans created KAFKA-15316:
--
Summary: CommitRequestManager not calling RequestState callbacks
Key: KAFKA-15316
URL: https://issues.apache.org/jira/browse/KAFKA-15316
Project: Kafka
Lianet Magrans created KAFKA-15306:
--
Summary: Integrate committed offsets logic when updating fetching
positions
Key: KAFKA-15306
URL: https://issues.apache.org/jira/browse/KAFKA-15306
Project:
Lianet Magrans created KAFKA-15270:
--
Summary: Integration tests for AsyncConsumer simple consume case
Key: KAFKA-15270
URL: https://issues.apache.org/jira/browse/KAFKA-15270
Project: Kafka
Lianet Magrans created KAFKA-15164:
--
Summary: Extract reusable logic from OffsetsForLeaderEpochClient
Key: KAFKA-15164
URL: https://issues.apache.org/jira/browse/KAFKA-15164
Project: Kafka
Lianet Magrans created KAFKA-15163:
--
Summary: Implement validatePositions functionality for new
KafkaConsumer
Key: KAFKA-15163
URL: https://issues.apache.org/jira/browse/KAFKA-15163
Project: Kafka
Lianet Magrans created KAFKA-15115:
--
Summary: Implement resetPositions functionality in
ListOffsetRequestManager
Key: KAFKA-15115
URL: https://issues.apache.org/jira/browse/KAFKA-15115
Project:
Lianet Magrans created KAFKA-15081:
--
Summary: Implement new consumer offsetsForTimes
Key: KAFKA-15081
URL: https://issues.apache.org/jira/browse/KAFKA-15081
Project: Kafka
Issue Type: Task
Lianet Magrans created KAFKA-14966:
--
Summary: Extract reusable common logic from OffsetFetcher
Key: KAFKA-14966
URL: https://issues.apache.org/jira/browse/KAFKA-14966
Project: Kafka
Issue
Lianet Magrans created KAFKA-14965:
--
Summary: Introduce ListOffsetsRequestManager to integrate
ListOffsetsRequests into new consumer threading refactor
Key: KAFKA-14965
URL:
92 matches
Mail list logo