Re: [PR] MINOR: Fix thread leak in AuthorizerIntegrationTest [kafka]

dajac merged PR #15006: URL: https://github.com/apache/kafka/pull/15006 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

Re: [PR] MINOR: Fix thread leak in AuthorizerIntegrationTest [kafka]

dajac commented on PR #15006: URL: https://github.com/apache/kafka/pull/15006#issuecomment-1862271647 Failed tests are not related. Merging to trunk and 3.7. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

Re: [PR] KAFKA-16002: Implement RemoteCopyLagSegments, RemoteDeleteLagBytes and RemoteDeleteLagSegments [kafka]

clolov commented on code in PR #15005: URL: https://github.com/apache/kafka/pull/15005#discussion_r1431012760 ## core/src/main/java/kafka/log/remote/RemoteLogManager.java: ## @@ -1071,15 +1085,38 @@ void cleanupExpiredRemoteLogSegments() throws RemoteStorageException,

[jira] [Resolved] (KAFKA-15158) Add metrics for RemoteDeleteRequestsPerSec, RemoteDeleteErrorsPerSec, BuildRemoteLogAuxStateRequestsPerSec, BuildRemoteLogAuxStateErrorsPerSec

[ https://issues.apache.org/jira/browse/KAFKA-15158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-15158. --- Resolution: Fixed > Add metrics for RemoteDeleteRequestsPerSec, RemoteDeleteErrorsPerSec, >

Re: [PR] KAFKA-15158: Add metrics for RemoteDelete and BuildRemoteLogAuxState [kafka]

showuon merged PR #14375: URL: https://github.com/apache/kafka/pull/14375 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

Re: [PR] KAFKA-15158: Add metrics for RemoteRequestsPerSec [kafka]

showuon commented on PR #14375: URL: https://github.com/apache/kafka/pull/14375#issuecomment-1862219804 Failed tests are unrelated. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

Re: [PR] MINOR: Use random cluster id for jsa file preparation [kafka]

omkreddy merged PR #15041: URL: https://github.com/apache/kafka/pull/15041 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

Re: [PR] KAFKA-16013: Added integration test for ExpiresPerSec metric [kafka]

showuon commented on PR #15015: URL: https://github.com/apache/kafka/pull/15015#issuecomment-1862142091 > @showuon Some of the existing tests in `DelayedRemoteFetchTest` are failing as the followerFetchParams are passed with a valid replicaId. I took liberty of fixing the existing tests in

Re: [PR] KAFKA-16013: Added integration test for ExpiresPerSec metric [kafka]

satishd commented on PR #15015: URL: https://github.com/apache/kafka/pull/15015#issuecomment-1862116069 @showuon Some of the existing tests in `DelayedRemoteFetchTest` are failing as the followerFetchParams are passed with a valid replicaId. I took liberty of fixing the existing tests in

Re: [PR] KAFKA-16012: Ensure new leader information merged correctly with the current metadata [kafka]

philipnee commented on PR #15023: URL: https://github.com/apache/kafka/pull/15023#issuecomment-1862113100 Hey @jolshan - Thanks again for the review. Addressed your comments in the latest commits. The only client-related failure is `testExpandingTopicSubscriptions`, a known flaky test. I

Re: [PR] KAFKA-15696: Refactor closing consumer [kafka]

philipnee commented on PR #14937: URL: https://github.com/apache/kafka/pull/14937#issuecomment-1862111535 Hey @lucasbru - I think your patch fixed the long running/oom issue with the async consumer test. The tests finished within 3.5hr in this commit:

Re: [PR] KAFKA-15696: Refactor closing consumer [kafka]

philipnee commented on PR #14937: URL: https://github.com/apache/kafka/pull/14937#issuecomment-1862105547 hey @lucasbru - Seems like your fix fixed the long running/oom issue with the test. The `testExpandingTopicSubscriptions` is on the flaky side, I've observed that in other PRs. --

[jira] [Assigned] (KAFKA-14511) Extend AlterIncrementalConfigs API to support group config

[ https://issues.apache.org/jira/browse/KAFKA-14511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lan Ding reassigned KAFKA-14511: Assignee: Lan Ding > Extend AlterIncrementalConfigs API to support group config >

Re: [PR] KAFKA-14401: Fail kafka log read end requests if underneath work thread is dead [kafka]

github-actions[bot] commented on PR #14372: URL: https://github.com/apache/kafka/pull/14372#issuecomment-1862052272 This PR is being marked as stale since it has not had any activity in 90 days. If you would like to keep this PR alive, please ask a committer for review. If the PR has

[jira] [Updated] (KAFKA-15803) Update last seen epoch during commit

[ https://issues.apache.org/jira/browse/KAFKA-15803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15803: -- Fix Version/s: 3.7.0 > Update last seen epoch during commit > >

[jira] [Updated] (KAFKA-15278) Implement client support for KIP-848 ConsumerGroupHeartbeat protocol RPC

[ https://issues.apache.org/jira/browse/KAFKA-15278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15278: -- Fix Version/s: 3.7.0 > Implement client support for KIP-848 ConsumerGroupHeartbeat protocol RPC >

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

[ https://issues.apache.org/jira/browse/KAFKA-15544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15544: -- Fix Version/s: 3.7.0 > Enable existing client integration tests for new protocol >

[jira] [Updated] (KAFKA-15280) Implement client support for selecting KIP-848 server-side assignor

[ https://issues.apache.org/jira/browse/KAFKA-15280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15280: -- Fix Version/s: 3.7.0 > Implement client support for selecting KIP-848 server-side assignor >

[jira] [Updated] (KAFKA-15890) Consumer.poll with long timeout unaware of assigned partitions

[ https://issues.apache.org/jira/browse/KAFKA-15890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15890: -- Fix Version/s: 3.7.0 > Consumer.poll with long timeout unaware of assigned partitions >

[jira] [Updated] (KAFKA-15833) Restrict Consumer API to be used from one thread

[ https://issues.apache.org/jira/browse/KAFKA-15833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15833: -- Fix Version/s: 3.7.0 > Restrict Consumer API to be used from one thread >

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

[ https://issues.apache.org/jira/browse/KAFKA-15164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15164: -- Fix Version/s: 3.7.0 > Extract reusable logic from OffsetsForLeaderEpochClient >

[jira] [Updated] (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 ] Kirk True updated KAFKA-15317: -- Fix Version/s: 3.7.0 > Fix for async consumer access to committed offsets with multiple consumers >

[jira] [Updated] (KAFKA-15562) Ensure fetch offset and commit offset handler handles both timeout and various error types

[ https://issues.apache.org/jira/browse/KAFKA-15562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15562: -- Fix Version/s: 3.7.0 > Ensure fetch offset and commit offset handler handles both timeout and >

[jira] [Updated] (KAFKA-15913) Migrate AsyncKafkaConsumerTest away from ConsumerTestBuilder

[ https://issues.apache.org/jira/browse/KAFKA-15913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15913: -- Fix Version/s: 3.7.0 > Migrate AsyncKafkaConsumerTest away from ConsumerTestBuilder >

[jira] [Updated] (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 ] Kirk True updated KAFKA-15573: -- Fix Version/s: 3.7.0 > Implement auto-commit on partition assignment revocation >

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

[ https://issues.apache.org/jira/browse/KAFKA-15679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15679: -- Fix Version/s: 3.7.0 > Client support for new consumer configs >

[jira] [Updated] (KAFKA-15840) Correct initialization of ConsumerGroupHeartbeat by client

[ https://issues.apache.org/jira/browse/KAFKA-15840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15840: -- Fix Version/s: 3.7.0 > Correct initialization of ConsumerGroupHeartbeat by client >

[jira] [Updated] (KAFKA-15865) Ensure consumer.poll() execute autocommit callback

[ https://issues.apache.org/jira/browse/KAFKA-15865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15865: -- Fix Version/s: 3.7.0 > Ensure consumer.poll() execute autocommit callback >

[jira] [Updated] (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 ] Kirk True updated KAFKA-15275: -- Fix Version/s: 3.7.0 > Implement consumer group membership state machine >

[jira] [Updated] (KAFKA-15184) New consumer internals refactoring and clean up

[ https://issues.apache.org/jira/browse/KAFKA-15184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15184: -- Fix Version/s: 3.7.0 > New consumer internals refactoring and clean up >

[jira] [Updated] (KAFKA-15842) Correct handling of KafkaConsumer.committed for new consumer

[ https://issues.apache.org/jira/browse/KAFKA-15842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15842: -- Fix Version/s: 3.7.0 > Correct handling of KafkaConsumer.committed for new consumer >

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

[ https://issues.apache.org/jira/browse/KAFKA-15554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15554: -- Fix Version/s: 3.7.0 > Update client state machine to align with protocol sending one assignment at

[jira] [Updated] (KAFKA-15533) Ensure HeartbeatRequestManager only send out some fields once

[ https://issues.apache.org/jira/browse/KAFKA-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15533: -- Fix Version/s: 3.7.0 > Ensure HeartbeatRequestManager only send out some fields once >

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

[ https://issues.apache.org/jira/browse/KAFKA-15631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15631: -- Fix Version/s: 3.7.0 > Do not send new heartbeat request while another one in-flight >

[jira] [Updated] (KAFKA-15932) Flaky test - PlaintextConsumerTest.testSeek("kraft+kip-848","consumer")

[ https://issues.apache.org/jira/browse/KAFKA-15932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15932: -- Fix Version/s: 3.7.0 > Flaky test - PlaintextConsumerTest.testSeek("kraft+kip-848","consumer") >

[jira] [Updated] (KAFKA-15592) Member does not need to always try to join a group when a groupId is configured

[ https://issues.apache.org/jira/browse/KAFKA-15592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15592: -- Fix Version/s: 3.7.0 > Member does not need to always try to join a group when a groupId is >

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

[ https://issues.apache.org/jira/browse/KAFKA-15316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15316: -- Fix Version/s: 3.7.0 > CommitRequestManager not calling RequestState callbacks >

[jira] [Updated] (KAFKA-15188) Implement more of the remaining PrototypeAsyncConsumer APIs

[ https://issues.apache.org/jira/browse/KAFKA-15188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15188: -- Fix Version/s: 3.7.0 > Implement more of the remaining PrototypeAsyncConsumer APIs >

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

[ https://issues.apache.org/jira/browse/KAFKA-15543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15543: -- Fix Version/s: 3.7.0 > Send HB request right after reconciliation completes >

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

[ https://issues.apache.org/jira/browse/KAFKA-15270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15270: -- Fix Version/s: 3.7.0 > Integration tests for AsyncConsumer simple consume case >

[jira] [Updated] (KAFKA-14675) Extract metadata-related tasks from Fetcher into MetadataFetcher

[ https://issues.apache.org/jira/browse/KAFKA-14675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-14675: -- Fix Version/s: 3.7.0 > Extract metadata-related tasks from Fetcher into MetadataFetcher >

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

[ https://issues.apache.org/jira/browse/KAFKA-15550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15550: -- Fix Version/s: 3.7.0 > OffsetsForTimes validation for negative timestamps in new consumer >

[jira] [Updated] (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 ] Kirk True updated KAFKA-15539: -- Fix Version/s: 3.7.0 > Client should stop fetching while partitions being revoked >

[jira] [Updated] (KAFKA-15651) Investigate auto commit guarantees during Consumer.assign()

[ https://issues.apache.org/jira/browse/KAFKA-15651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15651: -- Fix Version/s: 3.7.0 > Investigate auto commit guarantees during Consumer.assign() >

[jira] [Updated] (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 ] Kirk True updated KAFKA-15540: -- Fix Version/s: 3.7.0 > Handle heartbeat and revocation when consumer leaves group >

[jira] [Updated] (KAFKA-15887) Autocommit during close consistently fails with exception in background thread

[ https://issues.apache.org/jira/browse/KAFKA-15887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15887: -- Fix Version/s: 3.7.0 > Autocommit during close consistently fails with exception in background thread

[jira] [Updated] (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 ] Kirk True updated KAFKA-15438: -- Fix Version/s: 3.7.0 > Review exception caching logic used for reset/validate positions in async >

[jira] [Updated] (KAFKA-15694) New integration tests to have full coverage for preview

[ https://issues.apache.org/jira/browse/KAFKA-15694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15694: -- Fix Version/s: 3.7.0 > New integration tests to have full coverage for preview >

[jira] [Updated] (KAFKA-15174) Ensure the correct thread is executing the callbacks

[ https://issues.apache.org/jira/browse/KAFKA-15174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15174: -- Fix Version/s: 3.7.0 > Ensure the correct thread is executing the callbacks >

[jira] [Updated] (KAFKA-14247) Implement EventHandler interface and DefaultEventHandler for Consumer

[ https://issues.apache.org/jira/browse/KAFKA-14247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-14247: -- Fix Version/s: 3.7.0 > Implement EventHandler interface and DefaultEventHandler for Consumer >

[jira] [Updated] (KAFKA-15555) Ensure wakeups are handled correctly in PrototypeAsyncConsumer.poll()

[ https://issues.apache.org/jira/browse/KAFKA-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-1: -- Fix Version/s: 3.7.0 > Ensure wakeups are handled correctly in PrototypeAsyncConsumer.poll() >

[jira] [Updated] (KAFKA-14252) Create background thread skeleton for new Consumer threading model

[ https://issues.apache.org/jira/browse/KAFKA-14252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-14252: -- Fix Version/s: 3.7.0 > Create background thread skeleton for new Consumer threading model >

[jira] [Updated] (KAFKA-15534) Propagate client response time when timeout to the request handler

[ https://issues.apache.org/jira/browse/KAFKA-15534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15534: -- Fix Version/s: 3.7.0 > Propagate client response time when timeout to the request handler >

[jira] [Updated] (KAFKA-15281) Implement the groupMetadata Consumer API

[ https://issues.apache.org/jira/browse/KAFKA-15281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15281: -- Fix Version/s: 3.7.0 > Implement the groupMetadata Consumer API >

[jira] [Updated] (KAFKA-15531) Ensure coordinator node is removed upon disconnection exception

[ https://issues.apache.org/jira/browse/KAFKA-15531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15531: -- Fix Version/s: 3.7.0 > Ensure coordinator node is removed upon disconnection exception >

[jira] [Updated] (KAFKA-14246) Update threading model for Consumer

[ https://issues.apache.org/jira/browse/KAFKA-14246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-14246: -- Fix Version/s: 3.8.0 > Update threading model for Consumer > --- > >

[jira] [Commented] (KAFKA-15775) Implement listTopics() and partitionFor() for the AsyncKafkaConsumer

[ https://issues.apache.org/jira/browse/KAFKA-15775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798412#comment-17798412 ] Kirk True commented on KAFKA-15775: --- [~schofielaj]—please update the status of this Jira since this is

[jira] [Updated] (KAFKA-15775) Implement listTopics() and partitionFor() for the AsyncKafkaConsumer

[ https://issues.apache.org/jira/browse/KAFKA-15775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15775: -- Labels: consumer-threading-refactor kip-848 kip-848-client-support kip-848-e2e kip-848-preview (was:

[jira] [Created] (KAFKA-16031) Enabling testApplyDeltaShouldHandleReplicaAssignedToOnlineDirectory for tiered storage after supporting JBOD

Luke Chen created KAFKA-16031: - Summary: Enabling testApplyDeltaShouldHandleReplicaAssignedToOnlineDirectory for tiered storage after supporting JBOD Key: KAFKA-16031 URL:

[jira] [Updated] (KAFKA-15321) Document consumer group member state machine

[ https://issues.apache.org/jira/browse/KAFKA-15321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15321: -- Component/s: documentation > Document consumer group member state machine >

[jira] [Updated] (KAFKA-15691) Upgrade existing and add new system tests to use new consumer

[ https://issues.apache.org/jira/browse/KAFKA-15691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15691: -- Component/s: system tests > Upgrade existing and add new system tests to use new consumer >

[jira] [Updated] (KAFKA-15692) New integration tests to ensure full coverage

[ https://issues.apache.org/jira/browse/KAFKA-15692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15692: -- Component/s: unit tests > New integration tests to ensure full coverage >

[jira] [Updated] (KAFKA-15320) Document event queueing patterns

[ https://issues.apache.org/jira/browse/KAFKA-15320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15320: -- Component/s: documentation > Document event queueing patterns > > >

[jira] [Updated] (KAFKA-15999) Migrate HeartbeatRequestManagerTest away from ConsumerTestBuilder

[ https://issues.apache.org/jira/browse/KAFKA-15999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15999: -- Component/s: unit tests > Migrate HeartbeatRequestManagerTest away from ConsumerTestBuilder >

[jira] [Updated] (KAFKA-16000) Migrate MembershipManagerImplTest away from ConsumerTestBuilder

[ https://issues.apache.org/jira/browse/KAFKA-16000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16000: -- Summary: Migrate MembershipManagerImplTest away from ConsumerTestBuilder (was: Migrate

[jira] [Updated] (KAFKA-16000) Migrate MembershipManagerImpl away from ConsumerTestBuilder

[ https://issues.apache.org/jira/browse/KAFKA-16000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16000: -- Component/s: unit tests > Migrate MembershipManagerImpl away from ConsumerTestBuilder >

[jira] [Updated] (KAFKA-16024) SaslPlaintextConsumerTest#testCoordinatorFailover is flaky

[ https://issues.apache.org/jira/browse/KAFKA-16024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16024: -- Labels: consumer-threading-refactor flaky-test (was: consumer-threading-refactor) >

[jira] [Updated] (KAFKA-16024) SaslPlaintextConsumerTest#testCoordinatorFailover is flaky

[ https://issues.apache.org/jira/browse/KAFKA-16024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16024: -- Component/s: unit tests > SaslPlaintextConsumerTest#testCoordinatorFailover is flaky >

[jira] [Assigned] (KAFKA-16026) AsyncConsumer does not send a poll event to the background thread

[ https://issues.apache.org/jira/browse/KAFKA-16026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16026: - Assignee: Philip Nee > AsyncConsumer does not send a poll event to the background thread >

[jira] [Updated] (KAFKA-16026) AsyncConsumer does not send a poll event to the background thread

[ https://issues.apache.org/jira/browse/KAFKA-16026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16026: -- Fix Version/s: 3.7.0 > AsyncConsumer does not send a poll event to the background thread >

[jira] [Updated] (KAFKA-15818) Implement max poll interval

[ https://issues.apache.org/jira/browse/KAFKA-15818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15818: -- Labels: consumer-threading-refactor kip-848-client-support kip-848-e2e kip-848-preview (was:

[jira] [Updated] (KAFKA-15696) Revoke partitions on Consumer.close()

[ https://issues.apache.org/jira/browse/KAFKA-15696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15696: -- Labels: consumer-threading-refactor kip-848 kip-848-client-support kip-848-e2e kip-848-preview (was:

[jira] [Updated] (KAFKA-15696) Revoke partitions on Consumer.close()

[ https://issues.apache.org/jira/browse/KAFKA-15696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15696: -- Labels: consumer-threading-refactor kip-848-client-support kip-848-e2e kip-848-preview (was:

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

[ https://issues.apache.org/jira/browse/KAFKA-15550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15550: -- Labels: consumer-threading-refactor kip-848 kip-848-client-support kip-848-preview (was:

[jira] [Updated] (KAFKA-15281) Implement the groupMetadata Consumer API

[ https://issues.apache.org/jira/browse/KAFKA-15281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15281: -- Labels: consumer-threading-refactor kip-848-client-support kip-848-preview (was:

[jira] [Updated] (KAFKA-15548) Send GroupConsumerHeartbeatRequest on Consumer.close()

[ https://issues.apache.org/jira/browse/KAFKA-15548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15548: -- Labels: consumer-threading-refactor kip-848-client-support kip-848-e2e kip-848-preview (was:

[jira] [Updated] (KAFKA-15548) Send GroupConsumerHeartbeatRequest on Consumer.close()

[ https://issues.apache.org/jira/browse/KAFKA-15548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15548: -- Labels: consumer-threading-refactor kip-848 kip-848-client-support kip-848-e2e kip-848-preview (was:

[jira] [Updated] (KAFKA-15534) Propagate client response time when timeout to the request handler

[ https://issues.apache.org/jira/browse/KAFKA-15534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15534: -- Labels: consumer-threading-refactor kip-848-client-support kip-848-e2e kip-848-preview (was:

[jira] [Updated] (KAFKA-15277) Design & implement support for internal Consumer delegates

[ https://issues.apache.org/jira/browse/KAFKA-15277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15277: -- Labels: consumer-threading-refactor kip-848-client-support kip-848-e2e kip-848-preview (was:

[jira] [Updated] (KAFKA-15284) Implement ConsumerGroupProtocolVersionResolver to determine consumer group protocol

[ https://issues.apache.org/jira/browse/KAFKA-15284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15284: -- Labels: consumer-threading-refactor kip-848-client-support (was: consumer-threading-refactor kip-848

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

[ https://issues.apache.org/jira/browse/KAFKA-15550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15550: -- Labels: consumer-threading-refactor kip-848-client-support kip-848-preview (was:

[jira] [Updated] (KAFKA-15534) Propagate client response time when timeout to the request handler

[ https://issues.apache.org/jira/browse/KAFKA-15534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15534: -- Labels: consumer-threading-refactor kip-848 kip-848-client-support kip-848-e2e kip-848-preview (was:

[jira] [Updated] (KAFKA-15277) Design & implement support for internal Consumer delegates

[ https://issues.apache.org/jira/browse/KAFKA-15277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15277: -- Labels: consumer-threading-refactor kip-848 kip-848-client-support kip-848-e2e kip-848-preview (was:

[jira] [Updated] (KAFKA-15986) New consumer group protocol integration test failures

[ https://issues.apache.org/jira/browse/KAFKA-15986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15986: -- Labels: consumer-threading-refactor kip-848 kip-848-client-support (was: CTR

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

[ https://issues.apache.org/jira/browse/KAFKA-15991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15991: -- Labels: consumer-threading-refactor flaky-test kip-848 kip-848-client-support (was:

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

[ https://issues.apache.org/jira/browse/KAFKA-16004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16004: -- Labels: consumer-threading-refactor kip-848 kip-848-client-support (was: kip-848-client-support) >

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

[ https://issues.apache.org/jira/browse/KAFKA-15991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15991: -- Labels: consumer-threading-refactor flaky-test (was: flaky-test) > Flaky new consumer test

[jira] [Updated] (KAFKA-15842) Correct handling of KafkaConsumer.committed for new consumer

[ https://issues.apache.org/jira/browse/KAFKA-15842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15842: -- Labels: consumer-threading-refactor kip-848 kip-848-client-support kip-848-e2e kip-848-preview (was:

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

[ https://issues.apache.org/jira/browse/KAFKA-15954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15954: -- Labels: kip-848 kip-848-client-support (was: kip-848-client-support) > Review minimal effort

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

[ https://issues.apache.org/jira/browse/KAFKA-15991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15991: -- Component/s: unit tests > Flaky new consumer test testGroupIdNotNullAndValid >

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

[ https://issues.apache.org/jira/browse/KAFKA-15847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15847: -- Labels: (was: kip-848-client-support) > Allow to resolve client metadata for specific topics >

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

[ https://issues.apache.org/jira/browse/KAFKA-15847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15847: -- Component/s: consumer > Allow to resolve client metadata for specific topics >

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

[ https://issues.apache.org/jira/browse/KAFKA-15835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15835: -- Labels: kip-848 kip-848-client-support kip-848-e2e kip-848-preview (was: kip-848-client-support

[jira] [Updated] (KAFKA-15775) Implement listTopics() and partitionFor() for the AsyncKafkaConsumer

[ https://issues.apache.org/jira/browse/KAFKA-15775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15775: -- Labels: kip-848 kip-848-client-support kip-848-e2e kip-848-preview (was: kip-848-client-support

[jira] [Updated] (KAFKA-15840) Correct initialization of ConsumerGroupHeartbeat by client

[ https://issues.apache.org/jira/browse/KAFKA-15840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15840: -- Labels: kip-848 kip-848-client-support kip-848-e2e kip-848-preview (was: kip-848-client-support

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

[ https://issues.apache.org/jira/browse/KAFKA-15967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15967: -- Component/s: clients consumer Labels: kip-848 kip-848-client-support (was:

[jira] [Updated] (KAFKA-15953) Refactor polling delays

[ https://issues.apache.org/jira/browse/KAFKA-15953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15953: -- Component/s: consumer Labels: kip-848 kip-848-client-support (was: ) > Refactor polling

[jira] [Updated] (KAFKA-15846) Review consumer leave group request best effort

[ https://issues.apache.org/jira/browse/KAFKA-15846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15846: -- Labels: kip-848 kip-848-client-support (was: kip-848-client-support) > Review consumer leave group

[jira] [Updated] (KAFKA-15839) Improve TopicIdPartition integration in consumer membershipManager

[ https://issues.apache.org/jira/browse/KAFKA-15839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15839: -- Labels: kip-848 kip-848-client-support kip-848-e2e kip-848-preview (was: kip-848-client-support

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

[ https://issues.apache.org/jira/browse/KAFKA-15679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15679: -- Labels: kip-848 kip-848-client-support kip-848-e2e kip-848-preview (was: kip-848-client-support

  1   2   3   >