[jira] [Created] (KAFKA-16695) Improve expired poll interval logging by showing exceeded time

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

[jira] [Created] (KAFKA-16675) Move rebalance callback test for positions to callbacks test file

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

[jira] [Created] (KAFKA-16665) Fail to get partition's position from within onPartitionsAssigned callback in new consumer

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

[jira] [Created] (KAFKA-16628) Add system test for validating static consumer bounce and assignment when not eager

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

[jira] [Created] (KAFKA-16566) Update static membership fencing system test to support new protocol

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:

[jira] [Created] (KAFKA-16528) Reset member heartbeat interval when request sent

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

[jira] [Created] (KAFKA-16493) Avoid unneeded subscription regex check if metadata version unchanged

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:

[jira] [Created] (KAFKA-16418) Split long-running admin client integration tests

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

[jira] [Resolved] (KAFKA-16375) Fix logic for discarding reconciliation if member rejoined

[ 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 >

[jira] [Created] (KAFKA-16406) Split long-running consumer integration test

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:

[jira] [Created] (KAFKA-16375) Fix logic for discarding reconciliation if member rejoined

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

[jira] [Created] (KAFKA-16301) Review fenced member unsubscribe/subscribe callbacks interaction

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

[jira] [Created] (KAFKA-16298) Ensure user callbacks exceptions are propagated to the user on consumer poll

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

[jira] [Created] (KAFKA-16258) Stale member should trigger onPartitionsLost when leaving group

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

[jira] [Created] (KAFKA-16251) Fenced member should not send heartbeats while waiting for onPartitionsLost to complete

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

[jira] [Created] (KAFKA-16233) Review auto-commit continuously committing when no progress

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

[jira] [Resolved] (KAFKA-16133) Commits during reconciliation always time out

[ 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 >

[jira] [Created] (KAFKA-16224) Fix handling of deleted topic when auto-committing before revocation

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:

[jira] [Created] (KAFKA-16215) Consumer does not rejoin after fenced on delayed revocation

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

[jira] [Created] (KAFKA-16203) AutoCommit of empty offsets blocks following requests due to inflight flag

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

[jira] [Resolved] (KAFKA-16134) kafka.api.PlaintextConsumerTest.testPerPartitionLagMetricsCleanUpWithSubscribe(String, String).quorum=kraft+kip848.groupProtocol=consumer is flaky

[ 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

[jira] [Resolved] (KAFKA-16135) kafka.api.PlaintextConsumerTest.testPerPartitionLeadMetricsCleanUpWithSubscribe(String, String).quorum=kraft+kip848.groupProtocol=consumer is flaky

[ 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

[jira] [Created] (KAFKA-16190) Member should send full heartbeat when rejoining

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

[jira] [Created] (KAFKA-16185) Fix client reconciliation of same assignment received in different epochs

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

[jira] [Created] (KAFKA-16165) Consumer invalid transition on expired poll interval

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

[jira] [Created] (KAFKA-16156) System test failing on endOffsets with negative timestamps

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

[jira] [Reopened] (KAFKA-15538) Client support for java regex based subscription

[ 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 >

[jira] [Resolved] (KAFKA-15866) Refactor OffsetFetchRequestState Error handling to be more consistent with OffsetCommitRequestState

[ 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

[jira] [Created] (KAFKA-16107) Ensure consumer does not start fetching from added partitions until onPartitionsAssgined completes

Lianet Magrans created KAFKA-16107: -- Summary: Ensure consumer does not start fetching from added partitions until onPartitionsAssgined completes Key: KAFKA-16107 URL:

[jira] [Resolved] (KAFKA-15946) AsyncKafkaConsumer should retry commits on the application thread instead of auto-retry

[ 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

[jira] [Resolved] (KAFKA-15967) Fix revocation in reconcilation logic

[ 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

[jira] [Resolved] (KAFKA-15872) Investigate autocommit retry logic

[ 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

[jira] [Resolved] (KAFKA-15455) Add support for OffsetCommit version 9 in consumer

[ 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

[jira] [Resolved] (KAFKA-16099) Handle timeouts for AsyncKafkaConsumer.commitSync

[ 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

[jira] [Created] (KAFKA-16103) Review client logic for triggering offset commit callbacks

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

[jira] [Resolved] (KAFKA-15846) Review consumer leave group request best effort and response handling

[ 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

[jira] [Resolved] (KAFKA-15542) Release member assignments on errors

[ 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

[jira] [Resolved] (KAFKA-15515) Remove duplicated integration tests for new consumer

[ 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

[jira] [Resolved] (KAFKA-15325) Integrate topicId in OffsetFetch and OffsetCommit async consumer calls

[ 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

[jira] [Created] (KAFKA-16033) Review retry logic of OffsetFetch and OffsetCommit responses

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

[jira] [Created] (KAFKA-16032) Review inconsistent error handling of OffsetFetch and OffsetCommit responses

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

[jira] [Created] (KAFKA-16004) Review new consumer inflight offset commit logic

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

[jira] [Created] (KAFKA-15991) Flaky new consumer test testGroupIdNotNullAndValid

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

[jira] [Created] (KAFKA-15954) Review minimal effort approach on consumer last heartbeat on unsubscribe

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

[jira] [Created] (KAFKA-15847) Allow to resolve client metadata for specific topics

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

[jira] [Created] (KAFKA-15846) Review consumer leave group request

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

[jira] [Created] (KAFKA-15843) Review consumer onPartitionsAssigned called with empty partitions

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

[jira] [Created] (KAFKA-15839) Review topic recreation handling in client reconciliation

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

[jira] [Created] (KAFKA-15835) Group commit/callbacks triggering logic

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:

[jira] [Created] (KAFKA-15832) Trigger reconciliation based on manager poll

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:

[jira] [Resolved] (KAFKA-15317) Fix for async consumer access to committed offsets with multiple consumers

[ 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

[jira] [Resolved] (KAFKA-15539) Client should stop fetching while partitions being revoked

[ 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 >

[jira] [Resolved] (KAFKA-15573) Implement auto-commit on partition assignment revocation

[ 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 >

[jira] [Created] (KAFKA-15679) Client support new consumer configs

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

[jira] [Created] (KAFKA-15631) Do not send new heartbeat request while another one in-flight

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

[jira] [Resolved] (KAFKA-15540) Handle heartbeat and revocation when consumer leaves group

[ 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

[jira] [Created] (KAFKA-15561) Client support for new SubscriptionPattern based subscription

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

[jira] [Created] (KAFKA-15554) Update client state machine to align with protocol sending one assignment at a time

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

[jira] [Resolved] (KAFKA-15275) Implement consumer group membership state machine

[ 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 >

[jira] [Created] (KAFKA-15550) OffsetsForTimes validation for negative timestamps in new consumer

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:

[jira] [Created] (KAFKA-15544) Enable existing client integration tests for new protocol

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

[jira] [Created] (KAFKA-15543) Send HB request right after reconciliation completes

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

[jira] [Created] (KAFKA-15542) Release member assignments on errors

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:

[jira] [Resolved] (KAFKA-15438) Review exception caching logic used for reset/validate positions in async consumer

[ 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

[jira] [Resolved] (KAFKA-15164) Extract reusable logic from OffsetsForLeaderEpochClient

[ 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

[jira] [Created] (KAFKA-15540) Handle heartbeat and assignment release when consumer leaves group

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:

[jira] [Created] (KAFKA-15539) Stop fetching while partitions being revoked

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:

[jira] [Created] (KAFKA-15538) Resolve regex on client side when using java regex in new consumer

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:

[jira] [Created] (KAFKA-15515) Remove duplicated integration tests for new consumer

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

[jira] [Created] (KAFKA-15438) Review exception caching logic used for reset/validate positions in async consumer

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

[jira] [Created] (KAFKA-15327) Async consumer should commit offsets on close

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

[jira] [Created] (KAFKA-15325) Integrate topicId in OffsetFetch and OffsetCommit async consumer calls

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:

[jira] [Created] (KAFKA-15317) Fix for async consumer access to committed offsets with multiple consumers

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

[jira] [Created] (KAFKA-15316) CommitRequestManager not calling RequestState callbacks

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

[jira] [Created] (KAFKA-15306) Integrate committed offsets logic when updating fetching positions

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:

[jira] [Created] (KAFKA-15270) Integration tests for AsyncConsumer simple consume case

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

[jira] [Created] (KAFKA-15164) Extract reusable logic from OffsetsForLeaderEpochClient

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

[jira] [Created] (KAFKA-15163) Implement validatePositions functionality for new KafkaConsumer

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

[jira] [Created] (KAFKA-15115) Implement resetPositions functionality in ListOffsetRequestManager

Lianet Magrans created KAFKA-15115: -- Summary: Implement resetPositions functionality in ListOffsetRequestManager Key: KAFKA-15115 URL: https://issues.apache.org/jira/browse/KAFKA-15115 Project:

[jira] [Created] (KAFKA-15081) Implement new consumer offsetsForTimes

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

[jira] [Created] (KAFKA-14966) Extract reusable common logic from OffsetFetcher

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

[jira] [Created] (KAFKA-14965) Introduce ListOffsetsRequestManager to integrate ListOffsetsRequests into new consumer threading refactor

Lianet Magrans created KAFKA-14965: -- Summary: Introduce ListOffsetsRequestManager to integrate ListOffsetsRequests into new consumer threading refactor Key: KAFKA-14965 URL: