[jira] [Updated] (KAFKA-15282) Implement client support for KIP-848 client-side assignors

2024-01-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15282: -- Labels: kip-848-client-support (was: kip-848 kip-848-client-support) > Implement client support for

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

2024-01-30 Thread Kirk True (Jira)
[ 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-client-support (was: consumer-threading-refactor kip-848

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

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

[jira] [Updated] (KAFKA-15848) Consumer API timeout inconsistent between ConsumerDelegate implementations

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

[jira] [Updated] (KAFKA-15588) Purge the unsent offset commits/fetches when the member is fenced/failed

2024-01-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15588: -- Labels: kip-848-client-support (was: kip-848 kip-848-client-support) > Purge the unsent offset

[jira] [Updated] (KAFKA-16011) Fix PlaintextConsumerTest.testMultiConsumerSessionTimeoutOnClose

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

[jira] [Updated] (KAFKA-15283) Client support for OffsetFetch and OffsetCommit with topic ID

2024-01-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15283: -- Labels: kip-848-client-support newbie (was: kip-848 kip-848-client-support newbie) > Client support

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

2024-01-30 Thread Kirk True (Jira)
[ 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-client-support (was: kip-848 kip-848-client-support) > Review consumer leave group

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

2024-01-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15538: -- Labels: kip-848-client-support newbie (was: kip-848 kip-848-client-support newbie) > Client support

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

2024-01-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15321: -- Labels: kip-848-client-support (was: kip-848 kip-848-client-support) > Document consumer group

[jira] [Updated] (KAFKA-15839) Topic ID integration in consumer subscription state

2024-01-30 Thread Kirk True (Jira)
[ 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-client-support (was: kip-848 kip-848-client-support) > Topic ID integration in

[jira] [Updated] (KAFKA-15279) Implement client support for KIP-848 client-side assigner RPCs

2024-01-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15279: -- Labels: kip-848-client-support (was: kip-848 kip-848-client-support) > Implement client support for

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

2024-01-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15325: -- Labels: kip-848-client-support (was: kip-848 kip-848-client-support) > Integrate topicId in

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

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

[jira] [Updated] (KAFKA-16011) Fix PlaintextConsumerTest.testMultiConsumerSessionTimeoutOnClose

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

[jira] [Updated] (KAFKA-16198) Reconciliation may lose partitions when topic metadata is delayed

2024-01-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16198: -- Labels: client-transitions-issues kip-848-client-support (was: client-transitions-issues clients

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

2024-01-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16165: -- Labels: client-transitions-issues kip-848-client-support (was: client-transitions-issues) >

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

2024-01-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15846: -- Fix Version/s: 3.8.0 > Review consumer leave group request best effort and response handling >

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

2024-01-30 Thread Kirk True (Jira)
[ 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-15631) Do not send new heartbeat request while another one in-flight

2024-01-30 Thread Kirk True (Jira)
[ 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-15694) New integration tests to have full coverage for preview

2024-01-30 Thread Kirk True (Jira)
[ 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-15543) Send HB request right after reconciliation completes

2024-01-30 Thread Kirk True (Jira)
[ 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-15592) Member does not need to always try to join a group when a groupId is configured

2024-01-30 Thread Kirk True (Jira)
[ 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-15840) Correct initialization of ConsumerGroupHeartbeat by client

2024-01-30 Thread Kirk True (Jira)
[ 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-15573) Implement auto-commit on partition assignment revocation

2024-01-30 Thread Kirk True (Jira)
[ 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-15539) Client should stop fetching while partitions being revoked

2024-01-30 Thread Kirk True (Jira)
[ 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()

2024-01-30 Thread Kirk True (Jira)
[ 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-15270) Integration tests for AsyncConsumer simple consume case

2024-01-30 Thread Kirk True (Jira)
[ 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.8.0 > Integration tests for AsyncConsumer simple consume case >

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

2024-01-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15872: -- Fix Version/s: 3.8.0 > Investigate autocommit retry logic > -- > >

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

2024-01-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15515: -- Fix Version/s: 3.7.0 > Remove duplicated integration tests for new consumer >

[jira] [Updated] (KAFKA-16155) Investigate testAutoCommitIntercept

2024-01-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16155: -- Fix Version/s: 3.8.0 > Investigate testAutoCommitIntercept > --- > >

[jira] [Updated] (KAFKA-15697) Add local assignor and ensure it cannot be used with server side assignor

2024-01-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15697: -- Labels: kip-848-client-support (was: kip-848 kip-848-client-support kip-848-e2e kip-848-preview) >

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

2024-01-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15832: -- Labels: kip-848-client-support (was: kip-848 kip-848-client-support kip-848-e2e kip-848-preview) >

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

2024-01-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16037: -- Labels: kip-848-client-support (was: kip-848 kip-848-client-support kip-848-e2e kip-848-preview) >

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

2024-01-30 Thread Kirk True (Jira)
[ 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-client-support (was: kip-848 kip-848-client-support kip-848-e2e kip-848-preview) >

[jira] [Updated] (KAFKA-15691) Add new system tests to use new consumer

2024-01-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15691: -- Labels: kip-848-client-support (was: kip-848 kip-848-client-support kip-848-e2e kip-848-preview) >

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

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

[jira] [Updated] (KAFKA-15773) Group protocol configuration should be validated

2024-01-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15773: -- Labels: kip-848-client-support (was: kip-848 kip-848-client-support kip-848-e2e kip-848-preview) >

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

2024-01-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15843: -- Labels: kip-848 kip-848-client-support (was: kip-848 kip-848-client-support kip-848-e2e

[jira] [Updated] (KAFKA-14094) KIP-853: KRaft controller membership changes

2024-01-30 Thread Jira
[ https://issues.apache.org/jira/browse/KAFKA-14094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] José Armando García Sancio updated KAFKA-14094: --- Description:

[jira] [Updated] (KAFKA-16194) KafkaConsumer.groupMetadata() should be correct when first records are returned

2024-01-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16194: -- Fix Version/s: 3.8.0 > KafkaConsumer.groupMetadata() should be correct when first records are >

[jira] [Updated] (KAFKA-16194) KafkaConsumer.groupMetadata() should be correct when first records are returned

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

[jira] [Updated] (KAFKA-16156) System test failing for new consumer on endOffsets with negative timestamps

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

[jira] [Created] (KAFKA-16211) Inconsistent static config values in CreateTopicsResult and DescribeConfigsResult

2024-01-30 Thread Gantigmaa Selenge (Jira)
Gantigmaa Selenge created KAFKA-16211: - Summary: Inconsistent static config values in CreateTopicsResult and DescribeConfigsResult Key: KAFKA-16211 URL: https://issues.apache.org/jira/browse/KAFKA-16211

[jira] [Updated] (KAFKA-16211) Inconsistent config values in CreateTopicsResult and DescribeConfigsResult

2024-01-30 Thread Gantigmaa Selenge (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gantigmaa Selenge updated KAFKA-16211: -- Summary: Inconsistent config values in CreateTopicsResult and DescribeConfigsResult

Re: [PR] KAFKA-15853: Move AuthorizerUtils and its dependencies to server module [kafka]

2024-01-30 Thread via GitHub
OmniaGM commented on PR #15167: URL: https://github.com/apache/kafka/pull/15167#issuecomment-1917632608 Just rebased, it was an easy one -- 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

[jira] [Resolved] (KAFKA-8606) Provide a method to fetch committed offsets for a collection of TopicPartition

2024-01-30 Thread Andrew Schofield (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield resolved KAFKA-8606. - Fix Version/s: 2.4.0 Resolution: Fixed Method added in AK 2.4. > Provide a

Re: [PR] KAFKA-16157: fix topic recreation handling with offline disks [kafka]

2024-01-30 Thread via GitHub
OmniaGM commented on code in PR #15263: URL: https://github.com/apache/kafka/pull/15263#discussion_r1471733042 ## core/src/main/scala/kafka/cluster/Partition.scala: ## @@ -874,7 +874,13 @@ class Partition(val topicPartition: TopicPartition, private def

Re: [PR] KAFKA-14585: Refactoring for moving the storage tool [kafka]

2024-01-30 Thread via GitHub
fvaleri commented on code in PR #15273: URL: https://github.com/apache/kafka/pull/15273#discussion_r1471706520 ## raft/src/main/java/org/apache/kafka/raft/RaftConfig.java: ## @@ -206,6 +245,27 @@ private static Integer parseVoterId(String idString) { } } +

Re: [PR] KAFKA-14585: Refactoring for moving the storage tool [kafka]

2024-01-30 Thread via GitHub
fvaleri commented on code in PR #15273: URL: https://github.com/apache/kafka/pull/15273#discussion_r1471706520 ## raft/src/main/java/org/apache/kafka/raft/RaftConfig.java: ## @@ -206,6 +245,27 @@ private static Integer parseVoterId(String idString) { } } +

Re: [PR] KAFKA-15853: Move AuthorizerUtils and its dependencies to server module [kafka]

2024-01-30 Thread via GitHub
mimaison commented on PR #15167: URL: https://github.com/apache/kafka/pull/15167#issuecomment-1917615982 FYI I merged https://github.com/apache/kafka/pull/15246 and this indeed needs rebasing -- This is an automated message from the Apache Git Service. To respond to the message, please

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

2024-01-30 Thread Lianet Magrans (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lianet Magrans updated KAFKA-16165: --- Fix Version/s: 3.8.0 > Consumer invalid transition on expired poll interval >

Re: [PR] KAFKA-14585: Refactoring for moving the storage tool [kafka]

2024-01-30 Thread via GitHub
fvaleri commented on code in PR #15273: URL: https://github.com/apache/kafka/pull/15273#discussion_r1471706370 ## core/src/test/scala/unit/kafka/log/LogConfigTest.scala: ## @@ -94,6 +94,18 @@ class LogConfigTest { case TopicConfig.REMOTE_LOG_STORAGE_ENABLE_CONFIG =>

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

2024-01-30 Thread Lianet Magrans (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lianet Magrans updated KAFKA-16165: --- Affects Version/s: 3.7.0 > Consumer invalid transition on expired poll interval >

Re: [PR] KAFKA-15853: Move PasswordEncoder to server-common [kafka]

2024-01-30 Thread via GitHub
mimaison merged PR #15246: URL: https://github.com/apache/kafka/pull/15246 -- 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-16162: resend broker registration on metadata update to IBP 3.7-IV2 [kafka]

2024-01-30 Thread via GitHub
cmccabe commented on PR #15270: URL: https://github.com/apache/kafka/pull/15270#issuecomment-1917609564 Thanks, all. Committed. -- 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] KAFKA-16162: resend broker registration on metadata update to IBP 3.7-IV2 [kafka]

2024-01-30 Thread via GitHub
cmccabe closed pull request #15270: KAFKA-16162: resend broker registration on metadata update to IBP 3.7-IV2 URL: https://github.com/apache/kafka/pull/15270 -- 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

Re: [PR] KAFKA-14585: Refactoring for moving the storage tool [kafka]

2024-01-30 Thread via GitHub
fvaleri commented on code in PR #15273: URL: https://github.com/apache/kafka/pull/15273#discussion_r1471706370 ## core/src/test/scala/unit/kafka/log/LogConfigTest.scala: ## @@ -94,6 +94,18 @@ class LogConfigTest { case TopicConfig.REMOTE_LOG_STORAGE_ENABLE_CONFIG =>

Re: [PR] KAFKA-14585: Refactoring for moving the storage tool [kafka]

2024-01-30 Thread via GitHub
fvaleri commented on code in PR #15273: URL: https://github.com/apache/kafka/pull/15273#discussion_r1471706683 ## storage/src/main/java/org/apache/kafka/storage/internals/log/LogConfig.java: ## @@ -500,6 +553,34 @@ public static Map configKeys() { return

Re: [PR] KAFKA-14585: Refactoring for moving the storage tool [kafka]

2024-01-30 Thread via GitHub
fvaleri commented on code in PR #15273: URL: https://github.com/apache/kafka/pull/15273#discussion_r1471706253 ## storage/src/main/java/org/apache/kafka/storage/internals/log/LogConfig.java: ## @@ -290,7 +320,15 @@ public Optional serverConfigName(String configName) {

Re: [PR] MINOR: Cleanup log.dirs in ReplicaManagerTest on JVM exit [kafka]

2024-01-30 Thread via GitHub
gaurav-narula commented on PR #15289: URL: https://github.com/apache/kafka/pull/15289#issuecomment-1917579474 Addressed in [4406670](https://github.com/apache/kafka/pull/15289/commits/4406670459210eb7fac009c836288955c7bcb23c) > Shouldn't we instead update the tests to use temp

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

2024-01-30 Thread Lianet Magrans (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lianet Magrans updated KAFKA-16165: --- Labels: client-transitions-issues (was: ) > Consumer invalid transition on expired poll

[jira] [Resolved] (KAFKA-10184) Flaky HighAvailabilityTaskAssignorIntegrationTest.shouldScaleOutWithWarmupTasksAndPersistentStores

2024-01-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10184. - Assignee: (was: John Roesler) Resolution: Cannot Reproduce This ticket is

Re: [PR] KAFKA-16162: resend broker registration on metadata update to IBP 3.7-IV2 [kafka]

2024-01-30 Thread via GitHub
cmccabe commented on code in PR #15270: URL: https://github.com/apache/kafka/pull/15270#discussion_r1471687028 ## server-common/src/test/java/org/apache/kafka/common/DirectoryIdTest.java: ## @@ -67,18 +68,23 @@ void testCreateAssignmentMap() { @Test void

Re: [PR] KAFKA-15853: Move AuthorizerUtils and its dependencies to server module [kafka]

2024-01-30 Thread via GitHub
mimaison commented on PR #15167: URL: https://github.com/apache/kafka/pull/15167#issuecomment-1917549316 It's next on my list once https://github.com/apache/kafka/pull/15246 is merged. It will probably require you to rebase (sorry). -- This is an automated message from the Apache Git

Re: [PR] KAFKA-16204: Create partition dir for mockLog [kafka]

2024-01-30 Thread via GitHub
mimaison commented on PR #15288: URL: https://github.com/apache/kafka/pull/15288#issuecomment-1917532745 It's just a cleanup, not in any way related to a blocker item, hence why I'm asking. It's fine if you prefer to only accept commits fixing blockers in the 3.7 branch. Ultimately

Re: [PR] KAFKA-15853: Move AuthorizerUtils and its dependencies to server module [kafka]

2024-01-30 Thread via GitHub
OmniaGM commented on PR #15167: URL: https://github.com/apache/kafka/pull/15167#issuecomment-1917531480 Hi @mimaison can you review this pr please? -- 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

Re: [PR] KAFKA-16204: Create partition dir for mockLog [kafka]

2024-01-30 Thread via GitHub
stanislavkozlovski commented on PR #15288: URL: https://github.com/apache/kafka/pull/15288#issuecomment-1917509162 oh lol it's 3 lines, :shipit: -- 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

[jira] [Updated] (KAFKA-16200) Ensure RequestManager handling of expired timeouts are consistent

2024-01-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16200: -- Labels: consumer-threading-refactor timeout (was: consumer-threading-refactor consumer-timeout

[jira] [Updated] (KAFKA-16208) Design new Consumer timeout policy

2024-01-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16208: -- Labels: consumer-threading-refactor timeout (was: consumer-threading-refactor consumer-timeout

[jira] [Updated] (KAFKA-15848) Consumer API timeout inconsistent between ConsumerDelegate implementations

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

[jira] [Updated] (KAFKA-15475) Request might retry forever even if the user API timeout expires

2024-01-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15475: -- Labels: consumer-threading-refactor timeout (was: consumer-threading-refactor consumer-timeout

[jira] [Updated] (KAFKA-15558) Determine if Timer should be used elsewhere in PrototypeAsyncConsumer.updateFetchPositions()

2024-01-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15558: -- Labels: consumer-threading-refactor fetcher timeout (was: consumer-threading-refactor

[jira] [Updated] (KAFKA-16009) Fix PlaintextConsumerTest.testMaxPollIntervalMsDelayInRevocation

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

[jira] [Updated] (KAFKA-16199) Prune the event queue if event timeout expired before starting

2024-01-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16199: -- Labels: consumer-threading-refactor timeout (was: consumer-threading-refactor consumer-timeout

[jira] [Updated] (KAFKA-15974) Enforce that events and requests respect user-provided timeout

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

[jira] [Updated] (KAFKA-16008) Fix PlaintextConsumerTest.testMaxPollIntervalMs

2024-01-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16008: -- Labels: consumer-threading-refactor timeout (was: consumer-threading-refactor consumer-timeout

[jira] [Updated] (KAFKA-16100) Add timeout to all the CompletableApplicationEvents

2024-01-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16100: -- Labels: consumer-threading-refactor timeout (was: consumer-threading-refactor consumer-timeout

[jira] [Updated] (KAFKA-16010) Fix PlaintextConsumerTest.testMultiConsumerSessionTimeoutOnStopPolling

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

[jira] [Updated] (KAFKA-16009) Fix PlaintextConsumerTest.testMaxPollIntervalMsDelayInRevocation

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

[jira] [Updated] (KAFKA-15475) Request might retry forever even if the user API timeout expires

2024-01-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15475: -- Labels: consumer-threading-refactor consumer-timeout timeout (was: consumer-threading-refactor

[jira] [Updated] (KAFKA-16100) Add timeout to all the CompletableApplicationEvents

2024-01-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16100: -- Labels: consumer-threading-refactor consumer-timeout timeout (was: consumer-threading-refactor

[jira] [Updated] (KAFKA-16199) Prune the event queue if event timeout expired before starting

2024-01-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16199: -- Labels: consumer-threading-refactor consumer-timeout timeout (was: consumer-threading-refactor

[jira] [Updated] (KAFKA-16008) Fix PlaintextConsumerTest.testMaxPollIntervalMs

2024-01-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16008: -- Labels: consumer-threading-refactor consumer-timeout timeout (was: consumer-threading-refactor

[jira] [Updated] (KAFKA-16200) Ensure RequestManager handling of expired timeouts are consistent

2024-01-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16200: -- Labels: consumer-threading-refactor consumer-timeout timeout (was: consumer-threading-refactor

[jira] [Updated] (KAFKA-15974) Enforce that events and requests respect user-provided timeout

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

[jira] [Updated] (KAFKA-16010) Fix PlaintextConsumerTest.testMultiConsumerSessionTimeoutOnStopPolling

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

[jira] [Updated] (KAFKA-15848) Consumer API timeout inconsistent between ConsumerDelegate implementations

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

[jira] [Updated] (KAFKA-16208) Design new Consumer timeout policy

2024-01-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16208: -- Labels: consumer-threading-refactor consumer-timeout timeout (was: consumer-threading-refactor

[jira] [Updated] (KAFKA-15558) Determine if Timer should be used elsewhere in PrototypeAsyncConsumer.updateFetchPositions()

2024-01-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15558: -- Labels: consumer-threading-refactor consumer-timeout fetcher timeout (was:

[jira] [Updated] (KAFKA-16111) Implement tests for tricky rebalance callback scenarios

2024-01-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16111: -- Labels: callback consumer-threading-refactor kip-848-client-support (was: consumer-callbacks

[jira] [Updated] (KAFKA-15615) Improve handling of fetching during metadata updates

2024-01-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15615: -- Labels: consumer-threading-refactor fetcher (was: consumer-threading-refactor kip-848-preview) >

[jira] [Updated] (KAFKA-16029) Investigate cause of "Unable to find FetchSessionHandler for node X" in logs

2024-01-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16029: -- Labels: consumer-threading-refactor fetcher (was: consumer-threading-refactor) > Investigate cause

[jira] [Updated] (KAFKA-15558) Determine if Timer should be used elsewhere in PrototypeAsyncConsumer.updateFetchPositions()

2024-01-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15558: -- Labels: consumer-threading-refactor consumer-timeout fetcher (was: consumer-threading-refactor

[jira] [Updated] (KAFKA-16111) Implement tests for tricky rebalance callback scenarios

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

Re: [PR] KAFKA-16204: Create partition dir for mockLog [kafka]

2024-01-30 Thread via GitHub
stanislavkozlovski commented on PR #15288: URL: https://github.com/apache/kafka/pull/15288#issuecomment-1917467132 Can we add some detail as to what we benefit from backporting? Does it make some of the blocker fixes easier? -- This is an automated message from the Apache Git Service. To

Re: [PR] KAFKA-16107 [2/N]: Fix inverted args & more tests [kafka]

2024-01-30 Thread via GitHub
lianetm commented on PR #15285: URL: https://github.com/apache/kafka/pull/15285#issuecomment-1917462793 Hey @dajac , comment addressed and rebased, thanks! -- 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

Re: [PR] KAFKA-16107 [2/N]: Fix inverted args & more tests [kafka]

2024-01-30 Thread via GitHub
lianetm commented on code in PR #15285: URL: https://github.com/apache/kafka/pull/15285#discussion_r1471590270 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java: ## @@ -1160,7 +1160,7 @@ private CompletableFuture assignPartitions(

[jira] [Updated] (KAFKA-15558) Determine if Timer should be used elsewhere in PrototypeAsyncConsumer.updateFetchPositions()

2024-01-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15558: -- Labels: consumer-threading-refactor consumer-timeout (was: consumer-threading-refactor

Re: [PR] KAFKA-15675: Improve worker liveness check during Connect integration tests [kafka]

2024-01-30 Thread via GitHub
C0urante commented on PR #15249: URL: https://github.com/apache/kafka/pull/15249#issuecomment-1917431710 The [third CI run](https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-15249/8/tests/) also contained no failures for the

<    1   2   3   >