[jira] [Updated] (KAFKA-14782) Implementation Details Different from Documentation (delivery.timeout.ms)

2023-03-06 Thread jangho kwon (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jangho kwon updated KAFKA-14782: Description: Hello, I was checking the value related to {{{}delivery.timeout.ms{}}}, and I found

[jira] [Created] (KAFKA-14782) Implementation Details Different from Documentation (delivery.timeout.ms)

2023-03-06 Thread jangho kwon (Jira)
jangho kwon created KAFKA-14782: --- Summary: Implementation Details Different from Documentation (delivery.timeout.ms) Key: KAFKA-14782 URL: https://issues.apache.org/jira/browse/KAFKA-14782 Project:

[jira] [Created] (KAFKA-14781) MM2 logs misleading error during topic ACL sync when broker does not have authorizer configured

2023-03-06 Thread Chris Egerton (Jira)
Chris Egerton created KAFKA-14781: - Summary: MM2 logs misleading error during topic ACL sync when broker does not have authorizer configured Key: KAFKA-14781 URL: https://issues.apache.org/jira/browse/KAFKA-14781

[GitHub] [kafka] vamossagar12 commented on pull request #13127: KAFKA-14586: Moving StreamResetter to tools

2023-03-06 Thread via GitHub
vamossagar12 commented on PR #13127: URL: https://github.com/apache/kafka/pull/13127#issuecomment-1456365306 @cadonna , bumping this one again :) -- 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] [Comment Edited] (KAFKA-14091) Suddenly-killed tasks can leave hanging transactions open

2023-03-06 Thread Sagar Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696923#comment-17696923 ] Sagar Rao edited comment on KAFKA-14091 at 3/6/23 3:36 PM: --- hi [~ChrisEgerton]

[GitHub] [kafka] ivanyu commented on a diff in pull request #13067: KAFKA-14524: Rewrite KafkaMetricsGroup in Java

2023-03-06 Thread via GitHub
ivanyu commented on code in PR #13067: URL: https://github.com/apache/kafka/pull/13067#discussion_r1126571253 ## core/src/main/scala/kafka/network/RequestChannel.scala: ## @@ -497,51 +501,59 @@ object RequestMetrics { val ErrorsPerSec = "ErrorsPerSec" } -class

[GitHub] [kafka] ivanyu commented on a diff in pull request #13067: KAFKA-14524: Rewrite KafkaMetricsGroup in Java

2023-03-06 Thread via GitHub
ivanyu commented on code in PR #13067: URL: https://github.com/apache/kafka/pull/13067#discussion_r1126570518 ## server-common/src/main/java/org/apache/kafka/server/metrics/KafkaMetricsGroup.java: ## @@ -0,0 +1,160 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

[GitHub] [kafka] Hangleton commented on a diff in pull request #13240: KAFKA-14690: Add topic IDs to the OffsetCommit API version 9

2023-03-06 Thread via GitHub
Hangleton commented on code in PR #13240: URL: https://github.com/apache/kafka/pull/13240#discussion_r1126511918 ## clients/src/main/java/org/apache/kafka/common/requests/OffsetCommitResponse.java: ## @@ -167,8 +213,24 @@ public Builder addPartitions( }

[GitHub] [kafka] hudeqi opened a new pull request, #13348: MINOR: Fixed ProducerPerformance still counting successful sending when sending failed

2023-03-06 Thread via GitHub
hudeqi opened a new pull request, #13348: URL: https://github.com/apache/kafka/pull/13348 When using ProducerPerformance, I found that when the sending fails, it is still counted as successfully sent by stat and the metrics are printed. For example, when there is no write permission and

[jira] [Comment Edited] (KAFKA-14091) Suddenly-killed tasks can leave hanging transactions open

2023-03-06 Thread Sagar Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696923#comment-17696923 ] Sagar Rao edited comment on KAFKA-14091 at 3/6/23 12:40 PM: hi

[jira] [Commented] (KAFKA-14091) Suddenly-killed tasks can leave hanging transactions open

2023-03-06 Thread Sagar Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696923#comment-17696923 ] Sagar Rao commented on KAFKA-14091: --- hi [~ChrisEgerton] , I started working on this. Had a clarifying

[GitHub] [kafka] urbandan commented on pull request #10566: KAFKA-12694 Avoid schema mismatch DataException when validating default values

2023-03-06 Thread via GitHub
urbandan commented on PR #10566: URL: https://github.com/apache/kafka/pull/10566#issuecomment-1456046804 @C0urante sorry for the mixup in the exaple code, I did miss those setter calls. Thank you for the info and the code, I will check your solution. This problem does sound like

[jira] [Assigned] (KAFKA-14780) Make RefreshingHttpsJwksTest#testSecondaryRefreshAfterElapsedDelay deterministic

2023-03-06 Thread Alexandre Dupriez (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexandre Dupriez reassigned KAFKA-14780: - Assignee: Alexandre Dupriez > Make

[jira] [Updated] (KAFKA-14780) Make RefreshingHttpsJwksTest#testSecondaryRefreshAfterElapsedDelay deterministic

2023-03-06 Thread Alexandre Dupriez (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexandre Dupriez updated KAFKA-14780: -- Description: The test

[jira] [Updated] (KAFKA-14780) Make RefreshingHttpsJwksTest#testSecondaryRefreshAfterElapsedDelay deterministic

2023-03-06 Thread Alexandre Dupriez (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexandre Dupriez updated KAFKA-14780: -- Issue Type: Improvement (was: Test) > Make

[jira] [Updated] (KAFKA-14780) Make RefreshingHttpsJwksTest#testSecondaryRefreshAfterElapsedDelay deterministic

2023-03-06 Thread Alexandre Dupriez (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexandre Dupriez updated KAFKA-14780: -- Description: The test

[jira] [Commented] (KAFKA-14780) Make RefreshingHttpsJwksTest#testSecondaryRefreshAfterElapsedDelay deterministic

2023-03-06 Thread Alexandre Dupriez (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696882#comment-17696882 ] Alexandre Dupriez commented on KAFKA-14780: --- [~kirktrue], would you agree with the approach?

[jira] [Created] (KAFKA-14780) Make RefreshingHttpsJwksTest#testSecondaryRefreshAfterElapsedDelay deterministic

2023-03-06 Thread Alexandre Dupriez (Jira)
Alexandre Dupriez created KAFKA-14780: - Summary: Make RefreshingHttpsJwksTest#testSecondaryRefreshAfterElapsedDelay deterministic Key: KAFKA-14780 URL: https://issues.apache.org/jira/browse/KAFKA-14780

[jira] [Assigned] (KAFKA-14779) Add ACL Authorizer integration test for authorized OffsetCommits with an unknown topic

2023-03-06 Thread Alexandre Dupriez (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexandre Dupriez reassigned KAFKA-14779: - Assignee: Alexandre Dupriez > Add ACL Authorizer integration test for

[jira] [Created] (KAFKA-14779) Add ACL Authorizer integration test for authorized OffsetCommits with an unknown topic

2023-03-06 Thread Alexandre Dupriez (Jira)
Alexandre Dupriez created KAFKA-14779: - Summary: Add ACL Authorizer integration test for authorized OffsetCommits with an unknown topic Key: KAFKA-14779 URL: https://issues.apache.org/jira/browse/KAFKA-14779

[GitHub] [kafka] lucasbru commented on pull request #13347: MINOR: Use JUnit-5 extension to enforce strict stubbing

2023-03-06 Thread via GitHub
lucasbru commented on PR #13347: URL: https://github.com/apache/kafka/pull/13347#issuecomment-1455858009 @guozhangwang Could you have 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 the

[GitHub] [kafka] lucasbru commented on a diff in pull request #13336: MINOR: update RocksDBMetricsRecorder test to JUnit5 and fix memory leak

2023-03-06 Thread via GitHub
lucasbru commented on code in PR #13336: URL: https://github.com/apache/kafka/pull/13336#discussion_r1126203147 ## streams/src/test/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecorderTest.java: ## @@ -52,7 +52,6 @@ import static

[GitHub] [kafka] lucasbru opened a new pull request, #13347: MINOR: Use JUnit-5 extension to enforce strict stubbing

2023-03-06 Thread via GitHub
lucasbru opened a new pull request, #13347: URL: https://github.com/apache/kafka/pull/13347 Commit 32b1c23 disabled strict stubbing for the `RocksDBMetricsRecorderTest`. To re-enable the behavior in JUnit-5, we need to pull in a new dependency in the `streams` Gradle project.

[GitHub] [kafka] rajinisivaram opened a new pull request, #13346: KAFKA-14770: Allow dynamic keystore update for brokers if string representation of DN matches even if canonical DNs don't match

2023-03-06 Thread via GitHub
rajinisivaram opened a new pull request, #13346: URL: https://github.com/apache/kafka/pull/13346 To avoid mistakes during dynamic broker config updates that could potentially affect clients, we restrict changes that can be performed dynamically without broker restart. For broker keystore

[jira] [Created] (KAFKA-14778) Kafka Streams 2.7.1 to 3.3.1 rolling upgrade with static membership triggers a rebalance

2023-03-06 Thread Vinoth Rengarajan (Jira)
Vinoth Rengarajan created KAFKA-14778: - Summary: Kafka Streams 2.7.1 to 3.3.1 rolling upgrade with static membership triggers a rebalance Key: KAFKA-14778 URL:

[jira] [Commented] (KAFKA-14768) proposal to reduce the first message's send time cost and max block time for safety

2023-03-06 Thread fujian (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696794#comment-17696794 ] fujian commented on KAFKA-14768: Hi [~showuon]: I summary the two issues/solutions and create two KIPs

[GitHub] [kafka] jiafu1115 commented on pull request #13320: KAFKA-14768_KIP913: add new method to provide possibility for warming up first record's sending and reducing the max.block.ms safely.

2023-03-06 Thread via GitHub
jiafu1115 commented on PR #13320: URL: https://github.com/apache/kafka/pull/13320#issuecomment-1455730126 @divijvaidya KIP https://cwiki.apache.org/confluence/display/KAFKA/KIP-913%3A+add+new+method+to+provide+possibility+for+accelerate+first+record%27s+sending created. thanks --

[jira] [Commented] (KAFKA-14764) Metadata API ignores topic names if at least one topic ID is provided

2023-03-06 Thread Alexandre Dupriez (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696779#comment-17696779 ] Alexandre Dupriez commented on KAFKA-14764: --- One problem currently is that topics with a name

[GitHub] [kafka] satishd commented on a diff in pull request #13067: KAFKA-14524: Rewrite KafkaMetricsGroup in Java

2023-03-06 Thread via GitHub
satishd commented on code in PR #13067: URL: https://github.com/apache/kafka/pull/13067#discussion_r1125990307 ## server-common/src/main/java/org/apache/kafka/server/metrics/KafkaMetricsGroup.java: ## @@ -0,0 +1,160 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

[jira] [Updated] (KAFKA-14768) proposal to reduce the first message's send time cost and max block time for safety

2023-03-06 Thread fujian (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] fujian updated KAFKA-14768: --- Description: Hi, Team:   Nice to meet you!   In our business, we found two types of issue which need to

[GitHub] [kafka] Hangleton commented on pull request #13240: KAFKA-14690: Add topic IDs to the OffsetCommit API version 9

2023-03-06 Thread via GitHub
Hangleton commented on PR #13240: URL: https://github.com/apache/kafka/pull/13240#issuecomment-1455667030 Took a look at the authorizer tests (`AuthorizerIntegrationTests`). It seems that authorization with topic and group `READ` permissions and unknown topic name is not currently being

<    1   2