[GitHub] [kafka] machi1990 commented on pull request #13665: KAFKA-12485: Speed up Consumer#committed by returning cached offsets for owned partitions

2023-05-29 Thread via GitHub
machi1990 commented on PR #13665: URL: https://github.com/apache/kafka/pull/13665#issuecomment-1567839961 > Overall LGTM. Could we add tests to verify the committed offsets cache will be updated when the consumer committed some offests? Also, you could change to "non-draft" state when you'r

[GitHub] [kafka] DengShuaiSimon opened a new pull request, #13778: Feature/shuai add comment

2023-05-29 Thread via GitHub
DengShuaiSimon opened a new pull request, #13778: URL: https://github.com/apache/kafka/pull/13778 *More detailed description of your change, if necessary. The PR title and PR message become the squashed commit message, so use a separate comment to ping reviewers.* *Summary of

[GitHub] [kafka] KarboniteKream commented on a diff in pull request #13777: KAFKA-15036: UnknownServerError on any leader failover

2023-05-29 Thread via GitHub
KarboniteKream commented on code in PR #13777: URL: https://github.com/apache/kafka/pull/13777#discussion_r1209671539 ## metadata/src/main/java/org/apache/kafka/controller/QuorumController.java: ## @@ -2028,8 +2028,11 @@ public CompletableFuture finalizedFeatures( if (

[GitHub] [kafka] KarboniteKream commented on a diff in pull request #13777: KAFKA-15036: UnknownServerError on any leader failover

2023-05-29 Thread via GitHub
KarboniteKream commented on code in PR #13777: URL: https://github.com/apache/kafka/pull/13777#discussion_r1209671539 ## metadata/src/main/java/org/apache/kafka/controller/QuorumController.java: ## @@ -2028,8 +2028,11 @@ public CompletableFuture finalizedFeatures( if (

[GitHub] [kafka] KarboniteKream commented on a diff in pull request #13777: KAFKA-15036: UnknownServerError on any leader failover

2023-05-29 Thread via GitHub
KarboniteKream commented on code in PR #13777: URL: https://github.com/apache/kafka/pull/13777#discussion_r1209671539 ## metadata/src/main/java/org/apache/kafka/controller/QuorumController.java: ## @@ -2028,8 +2028,11 @@ public CompletableFuture finalizedFeatures( if (

[jira] [Assigned] (KAFKA-15036) Kraft leader change fails when invoking getFinalizedFeatures

2023-05-29 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming reassigned KAFKA-15036: --- Assignee: Deng Ziming > Kraft leader change fails when invoking getFinalizedFeatures >

[GitHub] [kafka] dengziming commented on pull request #13777: KAFKA-15036: UnknownServerError on any leader failover

2023-05-29 Thread via GitHub
dengziming commented on PR #13777: URL: https://github.com/apache/kafka/pull/13777#issuecomment-1567692572 @showuon @KarboniteKream @hachikuji I think this bug is very serious since it will stop any leader failover from functioning normally, so please take a look as soon as possible. --

[GitHub] [kafka] dengziming opened a new pull request, #13777: KAFKA-15036: UnknownServerError on any leader failover

2023-05-29 Thread via GitHub
dengziming opened a new pull request, #13777: URL: https://github.com/apache/kafka/pull/13777 *More detailed description of your change* This bug was introduced in #13679, we will invoke `finalizedFeatures` on receiving `ApiVersionRequest`, however, it's possible for a standby controller

[jira] [Created] (KAFKA-15036) Kraft leader change fails when invoking getFinalizedFeatures

2023-05-29 Thread Deng Ziming (Jira)
Deng Ziming created KAFKA-15036: --- Summary: Kraft leader change fails when invoking getFinalizedFeatures Key: KAFKA-15036 URL: https://issues.apache.org/jira/browse/KAFKA-15036 Project: Kafka I

[jira] [Commented] (KAFKA-7739) Kafka Tiered Storage

2023-05-29 Thread Henry Cai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17727229#comment-17727229 ] Henry Cai commented on KAFKA-7739: -- [~satish.duggana] It was mentioned that at the end o

[jira] [Created] (KAFKA-15035) Consumer offsets can be deleted immediately if kafka does not detect a consumer as dead

2023-05-29 Thread Sam Cantero (Jira)
Sam Cantero created KAFKA-15035: --- Summary: Consumer offsets can be deleted immediately if kafka does not detect a consumer as dead Key: KAFKA-15035 URL: https://issues.apache.org/jira/browse/KAFKA-15035

[GitHub] [kafka] vamossagar12 commented on pull request #13755: [MINOR] Fixing typo in ExactlyOnceWorkerSourceTask#commitableRecords

2023-05-29 Thread via GitHub
vamossagar12 commented on PR #13755: URL: https://github.com/apache/kafka/pull/13755#issuecomment-1567238790 Test failures seem 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 spec

[jira] [Commented] (KAFKA-15034) Improvement of ReplaceField performance for long list

2023-05-29 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17727119#comment-17727119 ] Yash Mayya commented on KAFKA-15034: Thanks for filing this ticket [~baz33]. I think

[jira] [Assigned] (KAFKA-15034) Improvement of ReplaceField performance for long list

2023-05-29 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya reassigned KAFKA-15034: -- Assignee: Yash Mayya > Improvement of ReplaceField performance for long list > --

[jira] [Updated] (KAFKA-15034) Improvement of ReplaceField performance for long list

2023-05-29 Thread BDeus (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] BDeus updated KAFKA-15034: -- Description: SMTs ReplaceField use List for include and exclude filter that use ArrayList internally. In cas

[jira] [Created] (KAFKA-15034) Improvement of ReplaceField performance for long list

2023-05-29 Thread BDeus (Jira)
BDeus created KAFKA-15034: - Summary: Improvement of ReplaceField performance for long list Key: KAFKA-15034 URL: https://issues.apache.org/jira/browse/KAFKA-15034 Project: Kafka Issue Type: Improveme

[GitHub] [kafka] showuon commented on pull request #13775: MINOR: update release.py

2023-05-29 Thread via GitHub
showuon commented on PR #13775: URL: https://github.com/apache/kafka/pull/13775#issuecomment-1566874959 @mimaison , call for review. 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 to go to the sp

[GitHub] [kafka] showuon opened a new pull request, #13775: MINOR: update release.py

2023-05-29 Thread via GitHub
showuon opened a new pull request, #13775: URL: https://github.com/apache/kafka/pull/13775 Update release.py script: 1. fix typo 2. remove non-existed `kafka-clie...@googlegroups.com` 3. add more info about closing repository in stagingRepository ### Committer Checklist (exclu

[jira] [Created] (KAFKA-15033) Failed to close repository in stagingRepositories

2023-05-29 Thread Luke Chen (Jira)
Luke Chen created KAFKA-15033: - Summary: Failed to close repository in stagingRepositories Key: KAFKA-15033 URL: https://issues.apache.org/jira/browse/KAFKA-15033 Project: Kafka Issue Type: Task

[jira] [Commented] (KAFKA-12317) Relax non-null key requirement for left/outer KStream joins

2023-05-29 Thread Domantas Petrauskas (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17727033#comment-17727033 ] Domantas Petrauskas commented on KAFKA-12317: - I am thinking about working o

[jira] [Commented] (KAFKA-10802) Spurious log message when starting consumers

2023-05-29 Thread t oo (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17727029#comment-17727029 ] t oo commented on KAFKA-10802: -- [~frosiere] did u solve? > Spurious log message when start

[jira] [Commented] (KAFKA-14956) Flaky test org.apache.kafka.connect.integration.OffsetsApiIntegrationTest#testGetSinkConnectorOffsetsDifferentKafkaClusterTargeted

2023-05-29 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17727025#comment-17727025 ] Yash Mayya commented on KAFKA-14956: This test seems to be consistently passing afte

[jira] [Resolved] (KAFKA-14956) Flaky test org.apache.kafka.connect.integration.OffsetsApiIntegrationTest#testGetSinkConnectorOffsetsDifferentKafkaClusterTargeted

2023-05-29 Thread Yash Mayya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yash Mayya resolved KAFKA-14956. Resolution: Fixed > Flaky test > org.apache.kafka.connect.integration.OffsetsApiIntegrationTest#t