[jira] [Assigned] (KAFKA-15737) KRaft support in ConsumerBounceTest

2024-01-08 Thread Kaushik Raina (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kaushik Raina reassigned KAFKA-15737: - Assignee: Kaushik Raina > KRaft support in ConsumerBounceTest >

Re: [PR] KAFKA-15388: Handling remote segment read in case of log compaction [kafka]

2024-01-08 Thread via GitHub
iit2009060 commented on PR #15060: URL: https://github.com/apache/kafka/pull/15060#issuecomment-1882517442 > auto-offset-reset > @iit2009060 The behaviour that you mentioned in the [comment](https://github.com/apache/kafka/pull/15060#issuecomment-1879657273) seems to be

[jira] [Assigned] (KAFKA-15738) KRaft support in ConsumerWithLegacyMessageFormatIntegrationTest

2024-01-08 Thread Abhinav Dixit (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abhinav Dixit reassigned KAFKA-15738: - Assignee: Abhinav Dixit > KRaft support in

Re: [PR] KAFKA-15388: Handling remote segment read in case of log compaction [kafka]

2024-01-08 Thread via GitHub
satishd commented on PR #15060: URL: https://github.com/apache/kafka/pull/15060#issuecomment-1882487316 @iit2009060 The behaviour that you mentioned in the [comment](https://github.com/apache/kafka/pull/15060#issuecomment-1879657273) seems to be working as expected. The client seems to

[jira] [Resolved] (KAFKA-15250) DefaultBackgroundThread is running tight loop

2024-01-08 Thread Philip Nee (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Philip Nee resolved KAFKA-15250. Fix Version/s: (was: 3.8.0) Resolution: Fixed > DefaultBackgroundThread is running

[jira] [Commented] (KAFKA-15250) DefaultBackgroundThread is running tight loop

2024-01-08 Thread Philip Nee (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804576#comment-17804576 ] Philip Nee commented on KAFKA-15250: i believe this is resolved. > DefaultBackgroundThread is

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

2024-01-08 Thread Philip Nee (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804574#comment-17804574 ] Philip Nee commented on KAFKA-15872: related https://issues.apache.org/jira/browse/KAFKA-15475 >

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

2024-01-08 Thread Philip Nee (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15872 ] Philip Nee deleted comment on KAFKA-15872: was (Author: JIRAUSER283568): this can be closed as duplicate of KAFKA-15946 > Investigate autocommit retry logic >

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

2024-01-08 Thread Philip Nee (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804573#comment-17804573 ] Philip Nee commented on KAFKA-15872: this can be closed as duplicate of KAFKA-15946 > Investigate

Re: [PR] MINOR: Add public documentation for metrics introduced in KIP-963 [kafka]

2024-01-08 Thread via GitHub
satishd commented on PR #15138: URL: https://github.com/apache/kafka/pull/15138#issuecomment-1882372491 Merged to trunk and 3.7 branches. cc @stanislavkozlovski -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

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

2024-01-08 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: -- Description: This task is to parameterize the tests to run twice: both for the old and the new

Re: [PR] KAFKA-15452: Access SslPrincipalMapper and kerberosShortNamer in Custom KafkaPrincipalBuilder(KIP-982) [kafka]

2024-01-08 Thread via GitHub
github-actions[bot] commented on PR #14504: URL: https://github.com/apache/kafka/pull/14504#issuecomment-1882343351 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

Re: [PR] KAFKA-15567 Fix benchmark code to work [kafka]

2024-01-08 Thread via GitHub
github-actions[bot] commented on PR #14513: URL: https://github.com/apache/kafka/pull/14513#issuecomment-1882343262 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

Re: [PR] MINOR: Add public documentation for metrics introduced in KIP-963 [kafka]

2024-01-08 Thread via GitHub
satishd merged PR #15138: URL: https://github.com/apache/kafka/pull/15138 -- 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:

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

2024-01-08 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: -- Summary: Client support for new SubscriptionPattern based subscription (was: Client support for new

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

2024-01-08 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: -- Summary: Client support for java regex based subscription (was: Client support for java regex based

[jira] [Updated] (KAFKA-15993) Enable max poll integration tests that depend on callback invocation

2024-01-08 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15993: -- Summary: Enable max poll integration tests that depend on callback invocation (was: Enable

Re: [PR] KAFKA-15468 [1/2]: Prevent transaction coordinator reloads on already loaded leaders [kafka]

2024-01-08 Thread via GitHub
artemlivshits commented on code in PR #15139: URL: https://github.com/apache/kafka/pull/15139#discussion_r1445523263 ## metadata/src/main/java/org/apache/kafka/image/LocalReplicaChanges.java: ## @@ -27,21 +27,24 @@ public final class LocalReplicaChanges { private final

[jira] [Updated] (KAFKA-15847) Consider partial metadata requests for client reconciliation

2024-01-08 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15847: -- Labels: consumer-threading-refactor (was: ) > Consider partial metadata requests for client

[jira] [Updated] (KAFKA-15847) Consider partial metadata requests for client reconciliation

2024-01-08 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15847: -- Fix Version/s: 3.8.0 > Consider partial metadata requests for client reconciliation >

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

2024-01-08 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: -- Fix Version/s: 3.8.0 (was: 4.0.0) > Improve handling of fetching during

[jira] [Updated] (KAFKA-15551) Evaluate conditions for short circuiting consumer API calls

2024-01-08 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15551: -- Fix Version/s: 3.8.0 (was: 4.0.0) > Evaluate conditions for short circuiting

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

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

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

2024-01-08 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15320: -- Fix Version/s: 3.8.0 (was: 4.0.0) > Document event queueing patterns >

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

2024-01-08 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: -- Fix Version/s: 3.8.0 (was: 4.0.0) > Document consumer group member state

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

2024-01-08 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: -- Fix Version/s: 4.0.0 (was: 3.8.0) > Add local assignor and ensure it cannot be

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

2024-01-08 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: -- Fix Version/s: 4.0.0 (was: 3.8.0) > Implement client support for KIP-848

[jira] [Updated] (KAFKA-15173) Consumer event queues should be bounded

2024-01-08 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15173: -- Fix Version/s: 3.8.0 (was: 4.0.0) > Consumer event queues should be bounded >

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

2024-01-08 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: -- Fix Version/s: 4.0.0 (was: 3.8.0) > Implement client support for KIP-848

Re: [PR] KAFKA-15468 [1/2]: Prevent transaction coordinator reloads on already loaded leaders [kafka]

2024-01-08 Thread via GitHub
jolshan commented on code in PR #15139: URL: https://github.com/apache/kafka/pull/15139#discussion_r1445497051 ## metadata/src/main/java/org/apache/kafka/image/LocalReplicaChanges.java: ## @@ -27,21 +27,24 @@ public final class LocalReplicaChanges { private final Set

Re: [PR] KAFKA-16093: Fix spurious REST-related warnings on Connect startup [kafka]

2024-01-08 Thread via GitHub
gharris1727 commented on code in PR #15149: URL: https://github.com/apache/kafka/pull/15149#discussion_r1445493874 ## connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectResource.java: ## @@ -16,12 +16,15 @@ */ package

Re: [PR] KAFKA-15468 [1/2]: Prevent transaction coordinator reloads on already loaded leaders [kafka]

2024-01-08 Thread via GitHub
jolshan commented on code in PR #15139: URL: https://github.com/apache/kafka/pull/15139#discussion_r1445493478 ## metadata/src/main/java/org/apache/kafka/image/LocalReplicaChanges.java: ## @@ -27,21 +27,24 @@ public final class LocalReplicaChanges { private final Set

[PR] KAFKA-16087: Avoid data race which drops wrong record when errors.tolerance=all and asynchronous error occurs [kafka]

2024-01-08 Thread via GitHub
gharris1727 opened a new pull request, #15154: URL: https://github.com/apache/kafka/pull/15154 The single ProcessingContext in the RetryWithToleranceOperator is subject to a data race when interacted with across multiple threads. Specifically, when the main task thread is converting

Re: [PR] KAFKA-16094: BrokerRegistrationRequest.logDirs field must be ignorable [kafka]

2024-01-08 Thread via GitHub
cmccabe commented on PR #15153: URL: https://github.com/apache/kafka/pull/15153#issuecomment-1881985343 In addition to the unit test in the PR, I verified manually that the bug is not present after the PR (and is before) -- This is an automated message from the Apache Git Service. To

[jira] [Updated] (KAFKA-16095) Update list group state type filter to include the states for the new consumer group type

2024-01-08 Thread Ritika Reddy (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ritika Reddy updated KAFKA-16095: - Description: # While using *—list —state* the current accepted values correspond to the

[jira] [Created] (KAFKA-16095) Update list group state type filter to include the states for the new consumer group type

2024-01-08 Thread Ritika Reddy (Jira)
Ritika Reddy created KAFKA-16095: Summary: Update list group state type filter to include the states for the new consumer group type Key: KAFKA-16095 URL: https://issues.apache.org/jira/browse/KAFKA-16095

[jira] [Commented] (KAFKA-16025) Streams StateDirectory has orphaned locks after rebalancing, blocking future rebalancing

2024-01-08 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804498#comment-17804498 ] A. Sophie Blee-Goldman commented on KAFKA-16025: FYI [~sabitn] I added you as a Jira

[jira] [Assigned] (KAFKA-16025) Streams StateDirectory has orphaned locks after rebalancing, blocking future rebalancing

2024-01-08 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reassigned KAFKA-16025: -- Assignee: Sabit > Streams StateDirectory has orphaned locks after

Re: [PR] KAFKA-14505; [4/N] Wire transaction verification [kafka]

2024-01-08 Thread via GitHub
jolshan commented on code in PR #15142: URL: https://github.com/apache/kafka/pull/15142#discussion_r1445444996 ## core/src/main/scala/kafka/coordinator/group/CoordinatorPartitionWriter.scala: ## @@ -201,18 +203,55 @@ class CoordinatorPartitionWriter[T]( )) } + /** +

Re: [PR] KAFKA-16025: Fix orphaned locks when rebalancing and store cleanup race on unassigned task directories [kafka]

2024-01-08 Thread via GitHub
ableegoldman merged PR #15088: URL: https://github.com/apache/kafka/pull/15088 -- 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:

[jira] [Updated] (KAFKA-16025) Streams StateDirectory has orphaned locks after rebalancing, blocking future rebalancing

2024-01-08 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-16025: --- Fix Version/s: 3.8.0 > Streams StateDirectory has orphaned locks after

Re: [PR] KAFKA-15460: Add group type filter to the List Groups API [kafka]

2024-01-08 Thread via GitHub
rreddy-22 closed pull request #14775: KAFKA-15460: Add group type filter to the List Groups API URL: https://github.com/apache/kafka/pull/14775 -- 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

Re: [PR] KAFKA-15460: Add group type filter to the List Groups API [kafka]

2024-01-08 Thread via GitHub
rreddy-22 commented on PR #14775: URL: https://github.com/apache/kafka/pull/14775#issuecomment-1881943833 Split into 2 PR's https://github.com/apache/kafka/pull/15150 https://github.com/apache/kafka/pull/15152 -- This is an automated message from the Apache Git Service. To respond

Re: [PR] KAFKA-16025: Fix orphaned locks when rebalancing and store cleanup race on unassigned task directories [kafka]

2024-01-08 Thread via GitHub
ableegoldman commented on PR #15088: URL: https://github.com/apache/kafka/pull/15088#issuecomment-1881943645 Test failures are unrelated, merging to trunk -- 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

[jira] [Assigned] (KAFKA-15462) Add group type filter to the admin client

2024-01-08 Thread Ritika Reddy (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ritika Reddy reassigned KAFKA-15462: Assignee: Ritika Reddy > Add group type filter to the admin client >

[PR] KAFKA-16094: BrokerRegistrationRequest.logDirs field must be ignorable [kafka]

2024-01-08 Thread via GitHub
cmccabe opened a new pull request, #15153: URL: https://github.com/apache/kafka/pull/15153 3.7 brokers must be able to register with 3.6 and earlier controllers. Currently, this is broken because we will unconditionally try to set logDirs, but this field cannot be sent with

Re: [PR] KAFKA-14505; [4/N] Wire transaction verification [kafka]

2024-01-08 Thread via GitHub
jolshan commented on code in PR #15142: URL: https://github.com/apache/kafka/pull/15142#discussion_r1445431424 ## group-coordinator/src/main/java/org/apache/kafka/coordinator/group/runtime/PartitionWriter.java: ## @@ -116,4 +120,21 @@ long appendEndTransactionMarker(

Re: [PR] KAFKA-14505; [4/N] Wire transaction verification [kafka]

2024-01-08 Thread via GitHub
jolshan commented on code in PR #15142: URL: https://github.com/apache/kafka/pull/15142#discussion_r1445426296 ## group-coordinator/src/main/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntime.java: ## @@ -1466,17 +1477,25 @@ public CompletableFuture

[jira] [Updated] (KAFKA-16094) BrokerRegistrationRequest.logDirs field must be ignorable

2024-01-08 Thread Colin McCabe (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin McCabe updated KAFKA-16094: - Summary: BrokerRegistrationRequest.logDirs field must be ignorable (was: 3.7 brokers must be

[jira] [Created] (KAFKA-16094) 3.7 brokers must be able to register with 3.6 and earlier controllers

2024-01-08 Thread Colin McCabe (Jira)
Colin McCabe created KAFKA-16094: Summary: 3.7 brokers must be able to register with 3.6 and earlier controllers Key: KAFKA-16094 URL: https://issues.apache.org/jira/browse/KAFKA-16094 Project: Kafka

Re: [PR] KAFKA-14505; [4/N] Wire transaction verification [kafka]

2024-01-08 Thread via GitHub
jolshan commented on code in PR #15142: URL: https://github.com/apache/kafka/pull/15142#discussion_r1445415307 ## core/src/main/scala/kafka/coordinator/group/CoordinatorPartitionWriter.scala: ## @@ -201,18 +203,55 @@ class CoordinatorPartitionWriter[T]( )) } + /** +

Re: [PR] KAFKA-14505; [4/N] Wire transaction verification [kafka]

2024-01-08 Thread via GitHub
jolshan commented on code in PR #15142: URL: https://github.com/apache/kafka/pull/15142#discussion_r1445412684 ## core/src/main/scala/kafka/server/ReplicaManager.scala: ## @@ -989,6 +989,7 @@ class ReplicaManager(val config: KafkaConfig, * @param requestLocal

Re: [PR] KAFKA-15756: [2/2] Migrate existing integration tests to run old protocol in new coordinator [kafka]

2024-01-08 Thread via GitHub
dongnuo123 commented on code in PR #14675: URL: https://github.com/apache/kafka/pull/14675#discussion_r1445392028 ## core/src/test/scala/integration/kafka/api/ConsumerBounceTest.scala: ## @@ -77,8 +83,9 @@ class ConsumerBounceTest extends AbstractConsumerTest with Logging {

Re: [PR] KAFKA-16093: Fix spurious REST-related warnings on Connect startup [kafka]

2024-01-08 Thread via GitHub
C0urante commented on code in PR #15149: URL: https://github.com/apache/kafka/pull/15149#discussion_r1445387176 ## connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectResource.java: ## @@ -16,12 +16,15 @@ */ package

Re: [PR] MINOR: set test global timeout as 10 mins [kafka]

2024-01-08 Thread via GitHub
ijuma commented on PR #15065: URL: https://github.com/apache/kafka/pull/15065#issuecomment-1881861076 This does actually work consistently? My experience with JUnit 5 timeout annotations has not been good, unfortunately (they often would simply not work at all). I haven't tried this

Re: [PR] KAFKA-15594: Add version 3.6 to Kafka Streams system tests [kafka]

2024-01-08 Thread via GitHub
mjsax commented on PR #15151: URL: https://github.com/apache/kafka/pull/15151#issuecomment-1881839122 Triggered system test run: https://jenkins.confluent.io/job/system-test-kafka-branch-builder/6021/ -- This is an automated message from the Apache Git Service. To respond to the message,

[PR] KAFKA-15460: Add group type filter to List Groups API [kafka]

2024-01-08 Thread via GitHub
rreddy-22 opened a new pull request, #15152: URL: https://github.com/apache/kafka/pull/15152 In KIP-848, we introduce the notion of Group Types based on the protocol type that the members in the consumer group use. As of now we support two types of groups: Classic : Members use the

[jira] [Assigned] (KAFKA-15744) KRaft support in CustomQuotaCallbackTest

2024-01-08 Thread Dmitry Werner (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dmitry Werner reassigned KAFKA-15744: - Assignee: (was: Dmitry Werner) > KRaft support in CustomQuotaCallbackTest >

Re: [PR] MINOR: set test global timeout as 10 mins [kafka]

2024-01-08 Thread via GitHub
dajac commented on PR #15065: URL: https://github.com/apache/kafka/pull/15065#issuecomment-1881833093 I like the idea! Have we been able to get a stable build with this? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Assigned] (KAFKA-15724) KRaft support in OffsetFetchRequestTest

2024-01-08 Thread Dmitry Werner (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dmitry Werner reassigned KAFKA-15724: - Assignee: (was: Dmitry Werner) > KRaft support in OffsetFetchRequestTest >

[jira] [Assigned] (KAFKA-15724) KRaft support in OffsetFetchRequestTest

2024-01-08 Thread Dmitry Werner (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dmitry Werner reassigned KAFKA-15724: - Assignee: Dmitry Werner > KRaft support in OffsetFetchRequestTest >

[PR] KAFKA-15594: Add version 3.6 to Kafka Streams system tests [kafka]

2024-01-08 Thread via GitHub
mjsax opened a new pull request, #15151: URL: https://github.com/apache/kafka/pull/15151 Needs to be cherry-picked to `3.7` branch -- 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

[jira] [Commented] (KAFKA-16084) Simplify and deduplicate StandaloneHerderTest mocking

2024-01-08 Thread Greg Harris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804460#comment-17804460 ] Greg Harris commented on KAFKA-16084: - [~cegerton] I agree. In this case, none of those conditions

Re: [PR] KAFKA-16093: Fix spurious REST-related warnings on Connect startup [kafka]

2024-01-08 Thread via GitHub
gharris1727 commented on code in PR #15149: URL: https://github.com/apache/kafka/pull/15149#discussion_r1445300416 ## connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectResource.java: ## @@ -16,12 +16,15 @@ */ package

[jira] [Assigned] (KAFKA-15744) KRaft support in CustomQuotaCallbackTest

2024-01-08 Thread Dmitry Werner (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dmitry Werner reassigned KAFKA-15744: - Assignee: Dmitry Werner > KRaft support in CustomQuotaCallbackTest >

Re: [PR] KAFKA-15721: KRaft support in DeleteTopicsRequestWithDeletionDisabledTest [kafka]

2024-01-08 Thread via GitHub
wernerdv commented on PR #15124: URL: https://github.com/apache/kafka/pull/15124#issuecomment-1881716010 @mimaison take a look, 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 to the

[PR] KAFKA-15462: Add Group Type Filter for List Group to the Admin Client [kafka]

2024-01-08 Thread via GitHub
rreddy-22 opened a new pull request, #15150: URL: https://github.com/apache/kafka/pull/15150 In KIP-848, we introduce the notion of Group Types based on the protocol type that the members in the consumer group use. As of now we support two types of groups: 1) Classic : Members use the

Re: [PR] KAFKA-14505; [4/N] Wire transaction verification [kafka]

2024-01-08 Thread via GitHub
jolshan commented on PR #15142: URL: https://github.com/apache/kafka/pull/15142#issuecomment-1881648674 Yup -- sorry was hoping to do all the clean ups before you got to this -- but shouldn't be too hard to update. -- This is an automated message from the Apache Git Service. To respond

[PR] KAFKA-16093: Fix spurious REST-related warnings on Connect startup [kafka]

2024-01-08 Thread via GitHub
C0urante opened a new pull request, #15149: URL: https://github.com/apache/kafka/pull/15149 [Jira](https://issues.apache.org/jira/browse/KAFKA-16093) ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI

[jira] [Created] (KAFKA-16093) Spurious warnings logged to stderr about empty path annotations and providers not implementing provider interfaces

2024-01-08 Thread Chris Egerton (Jira)
Chris Egerton created KAFKA-16093: - Summary: Spurious warnings logged to stderr about empty path annotations and providers not implementing provider interfaces Key: KAFKA-16093 URL:

Re: [PR] KAFKA-15807: Added support for compression of metrics (KIP-714) [kafka]

2024-01-08 Thread via GitHub
apoorvmittal10 commented on PR #15148: URL: https://github.com/apache/kafka/pull/15148#issuecomment-1881633923 @AndrewJSchofield @mjsax @kirktrue @philipnee Please review. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

Re: [PR] KAFKA-15807: Added support for compression of metrics (KIP-714) [kafka]

2024-01-08 Thread via GitHub
apoorvmittal10 commented on code in PR #15148: URL: https://github.com/apache/kafka/pull/15148#discussion_r1445133177 ## clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryUtils.java: ## @@ -175,16 +182,44 @@ public static boolean

Re: [PR] KAFKA-15807: Added support for compression of metrics (KIP-714) [kafka]

2024-01-08 Thread via GitHub
apoorvmittal10 commented on code in PR #15148: URL: https://github.com/apache/kafka/pull/15148#discussion_r1445128354 ## clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryUtils.java: ## @@ -175,16 +182,44 @@ public static boolean

Re: [PR] KAFKA-16083: Exclude throttle time when expiring inflight requests on a connection [kafka]

2024-01-08 Thread via GitHub
ditac commented on PR #15130: URL: https://github.com/apache/kafka/pull/15130#issuecomment-1881622932 The following tests failed across runs but they dont seem related to this change - ``` testReplicateFromLatest() –

[PR] KAFKA-15807: Added support for compression of metrics (KIP-714) [kafka]

2024-01-08 Thread via GitHub
apoorvmittal10 opened a new pull request, #15148: URL: https://github.com/apache/kafka/pull/15148 Adds support for compression/decompression of metrics defined in KIP-714. ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify

Re: [PR] MINOR: Update documentation.html with the 3.7 release [kafka]

2024-01-08 Thread via GitHub
stanislavkozlovski commented on code in PR #15010: URL: https://github.com/apache/kafka/pull/15010#discussion_r1445107285 ## docs/documentation.html: ## @@ -60,6 +60,7 @@ Kafka 3.6 Documentation 3.3.X. 3.4.X. 3.5.X.

[jira] [Updated] (KAFKA-16082) JBOD: Possible dataloss when moving leader partition

2024-01-08 Thread Stanislav Kozlovski (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-16082: Fix Version/s: 3.7.0 > JBOD: Possible dataloss when moving leader partition >

[jira] [Updated] (KAFKA-16092) Queues for Kafka

2024-01-08 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-16092: Issue Type: New Feature (was: Improvement) > Queues for Kafka > > >

[jira] [Updated] (KAFKA-16089) Kafka Streams still leaking memory in 3.7

2024-01-08 Thread Stanislav Kozlovski (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-16089: Fix Version/s: 3.7.0 > Kafka Streams still leaking memory in 3.7 >

Re: [PR] KAFKA-16025: Fix orphaned locks when rebalancing and store cleanup race on unassigned task directories [kafka]

2024-01-08 Thread via GitHub
sanepal commented on code in PR #15088: URL: https://github.com/apache/kafka/pull/15088#discussion_r1445046684 ## streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java: ## @@ -1229,10 +1229,21 @@ private void tryToLockAllNonEmptyTaskDirectories() {

[jira] [Created] (KAFKA-16092) Queues for Kafka

2024-01-08 Thread Andrew Schofield (Jira)
Andrew Schofield created KAFKA-16092: Summary: Queues for Kafka Key: KAFKA-16092 URL: https://issues.apache.org/jira/browse/KAFKA-16092 Project: Kafka Issue Type: Improvement

[jira] [Updated] (KAFKA-15839) Review topic ID integration in consumer reconciliation process

2024-01-08 Thread Lianet Magrans (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lianet Magrans updated KAFKA-15839: --- Parent: KAFKA-14048 Issue Type: Sub-task (was: Improvement) > Review topic ID

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

2024-01-08 Thread Lianet Magrans (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lianet Magrans updated KAFKA-15954: --- Parent: KAFKA-14048 Issue Type: Sub-task (was: Improvement) > Review minimal

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

2024-01-08 Thread Lianet Magrans (Jira)
[ 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] [Updated] (KAFKA-15843) Review consumer onPartitionsAssigned called with empty partitions

2024-01-08 Thread Lianet Magrans (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lianet Magrans updated KAFKA-15843: --- Parent: KAFKA-14048 Issue Type: Sub-task (was: Improvement) > Review consumer

[PR] KAFKA-7957: Enable testMetricsReporterUpdate [kafka]

2024-01-08 Thread via GitHub
mimaison opened a new pull request, #15147: URL: https://github.com/apache/kafka/pull/15147 Ignore for now, I'm investigating this flaky test ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build

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

2024-01-08 Thread Lianet Magrans (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lianet Magrans updated KAFKA-15846: --- Parent: KAFKA-14048 Issue Type: Sub-task (was: Improvement) > Review consumer

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

2024-01-08 Thread Lianet Magrans (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lianet Magrans updated KAFKA-15846: --- Summary: Review consumer leave group request best effort and response handling (was:

Re: [PR] KAFKA-14589 ConsumerGroupCommand options and case classes rewritten [kafka]

2024-01-08 Thread via GitHub
nizhikov commented on PR #14856: URL: https://github.com/apache/kafka/pull/14856#issuecomment-1881507357 @mimaison can you, please, take a look. -- 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-15846) Review consumer leave group request best effort

2024-01-08 Thread Lianet Magrans (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lianet Magrans updated KAFKA-15846: --- Description: New consumer sends out a leave group request with a best effort approach.

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

2024-01-08 Thread Lianet Magrans (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lianet Magrans updated KAFKA-15835: --- Parent: KAFKA-14048 Issue Type: Sub-task (was: Improvement) > Group

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

2024-01-08 Thread Lianet Magrans (Jira)
[ 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] [Updated] (KAFKA-15538) Client support for java regex based subscription

2024-01-08 Thread Lianet Magrans (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lianet Magrans updated KAFKA-15538: --- Parent: KAFKA-14048 Issue Type: Sub-task (was: New Feature) > Client support for

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

2024-01-08 Thread Lianet Magrans (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lianet Magrans updated KAFKA-16032: --- Summary: Review client inconsistent error handling of OffsetFetch and OffsetCommit

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

2024-01-08 Thread Lianet Magrans (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lianet Magrans updated KAFKA-16033: --- Parent: KAFKA-14048 Issue Type: Sub-task (was: Improvement) > Review client retry

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

2024-01-08 Thread Lianet Magrans (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lianet Magrans updated KAFKA-16033: --- Summary: Review client retry logic of OffsetFetch and OffsetCommit responses (was: Review

[jira] [Updated] (KAFKA-15847) Consider partial metadata requests for client reconciliation

2024-01-08 Thread Lianet Magrans (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lianet Magrans updated KAFKA-15847: --- Description: New consumer implementing KIP-848 protocol needs to resolve metadata for the

[jira] [Updated] (KAFKA-15847) Consider partial metadata requests for client reconciliation

2024-01-08 Thread Lianet Magrans (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lianet Magrans updated KAFKA-15847: --- Summary: Consider partial metadata requests for client reconciliation (was: Allow to

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

2024-01-08 Thread Lianet Magrans (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lianet Magrans updated KAFKA-15847: --- Description: Currently metadata updates requested through the metadata object request

Re: [PR] KAFKA-14588 Move DynamicConfig to server-commons [kafka]

2024-01-08 Thread via GitHub
mimaison commented on PR #14871: URL: https://github.com/apache/kafka/pull/14871#issuecomment-188143 Note there's also https://github.com/apache/kafka/pull/15103 which is attempting to move KafkaConfig to the server module. You may want to sync with Omnia to avoid duplicating work.

  1   2   >