[jira] [Created] (KAFKA-13924) purging a Kafka topic at an specific time and interval

2022-05-21 Thread Amin Qurjili (Jira)
Amin Qurjili created KAFKA-13924: Summary: purging a Kafka topic at an specific time and interval Key: KAFKA-13924 URL: https://issues.apache.org/jira/browse/KAFKA-13924 Project: Kafka Issue

[jira] [Created] (KAFKA-13925) Интеграция информационно-финансовых систем

2022-05-21 Thread Yudin Nikita (Jira)
Yudin Nikita created KAFKA-13925: Summary: Интеграция информационно-финансовых систем Key: KAFKA-13925 URL: https://issues.apache.org/jira/browse/KAFKA-13925 Project: Kafka Issue Type: Test

[GitHub] [kafka] C0urante opened a new pull request, #12191: KAFKA-12657: Increase timeouts in Connect integration tests

2022-05-21 Thread GitBox
C0urante opened a new pull request, #12191: URL: https://github.com/apache/kafka/pull/12191 [Jira](https://github.com/C0urante/kafka/pull/new/kafka-12657) As an initial step to address the notoriously flaky `BlockingConnectorTest` test suite, we can try increasing test timeouts.

[jira] [Commented] (KAFKA-12657) Flaky Tests BlockingConnectorTest.testWorkerRestartWithBlockInConnectorStop

2022-05-21 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17540423#comment-17540423 ] Chris Egerton commented on KAFKA-12657: --- Giving it a shot with [https://github.com

[jira] [Commented] (KAFKA-13856) MirrorCheckpointTask meets ConcurrentModificationException

2022-05-21 Thread Kvicii.Yu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17540430#comment-17540430 ] Kvicii.Yu commented on KAFKA-13856: --- [~Justinwins]  we use ConcurrentHashMap instead o

[GitHub] [kafka] C0urante commented on pull request #12191: KAFKA-12657: Increase timeouts in Connect integration tests

2022-05-21 Thread GitBox
C0urante commented on PR #12191: URL: https://github.com/apache/kafka/pull/12191#issuecomment-1133642820 😂 thanks for the LGTM but I think we may want to wait for some test results first! -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [kafka] Kvicii commented on pull request #12191: KAFKA-12657: Increase timeouts in Connect integration tests

2022-05-21 Thread GitBox
Kvicii commented on PR #12191: URL: https://github.com/apache/kafka/pull/12191#issuecomment-1133644673 Sure, but I think it’s a normal PR👍 > On May 21, 2022, at 22:23, Chris Egerton ***@***.***> wrote: > > -- This is an automated message from the Apache Git Service.

[GitHub] [kafka] hachikuji commented on a diff in pull request #12187: KAFKA-13858; Kraft should not shutdown metadata listener until controller shutdown is finished

2022-05-21 Thread GitBox
hachikuji commented on code in PR #12187: URL: https://github.com/apache/kafka/pull/12187#discussion_r878712671 ## core/src/main/scala/kafka/server/ReplicaManager.scala: ## @@ -2134,10 +2141,13 @@ class ReplicaManager(val config: KafkaConfig, stateChangeLogger.trace

[GitHub] [kafka] C0urante commented on pull request #12191: KAFKA-12657: Increase timeouts in Connect integration tests

2022-05-21 Thread GitBox
C0urante commented on PR #12191: URL: https://github.com/apache/kafka/pull/12191#issuecomment-1133668291 Drafted an approach for item 1 with https://github.com/C0urante/kafka/pull/1 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [kafka] C0urante commented on pull request #12191: KAFKA-12657: Increase timeouts in Connect integration tests

2022-05-21 Thread GitBox
C0urante commented on PR #12191: URL: https://github.com/apache/kafka/pull/12191#issuecomment-1133669167 Drafted an approach for item 2 (that also addresses the major issue with item 3, which is that artificially reducing the REST request timeout impacts unrelated Connect integration tests

[GitHub] [kafka] C0urante commented on pull request #12191: KAFKA-12657: Increase timeouts in Connect integration tests

2022-05-21 Thread GitBox
C0urante commented on PR #12191: URL: https://github.com/apache/kafka/pull/12191#issuecomment-1133669242 Going to keep this PR as-is until we can get more data on whether increasing the timeouts is sufficient for Jenkins. -- This is an automated message from the Apache Git Service. To res

[GitHub] [kafka] C0urante commented on pull request #11778: KAFKA-10000: Use transactional producer for config topic (KIP-618)

2022-05-21 Thread GitBox
C0urante commented on PR #11778: URL: https://github.com/apache/kafka/pull/11778#issuecomment-1133671099 @tombentley the 3.3.0 feature freeze is a little over a month away and there are still seven open pull requests for this feature. Do you have time to take a look? I -- This is an auto

[GitHub] [kafka] C0urante commented on pull request #11776: KAFKA-10000: Add new preflight connector config validation logic (KIP-618)

2022-05-21 Thread GitBox
C0urante commented on PR #11776: URL: https://github.com/apache/kafka/pull/11776#issuecomment-1133671126 @showuon the 3.3.0 feature freeze is a little over a month away and there are still seven open pull requests for this feature. Do you have time to take a look? I -- This is an automat

[GitHub] [kafka] guozhangwang merged pull request #12189: Fix flaky test TopicCommandIntegrationTest.testDescribeAtMinIsrPartitions(String).quorum=kraft

2022-05-21 Thread GitBox
guozhangwang merged PR #12189: URL: https://github.com/apache/kafka/pull/12189 -- 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-unsubscr...@kafka.ap

[GitHub] [kafka] guozhangwang commented on a diff in pull request #12121: KAFKA-13846: Adding overloaded metricOrElseCreate method

2022-05-21 Thread GitBox
guozhangwang commented on code in PR #12121: URL: https://github.com/apache/kafka/pull/12121#discussion_r878742212 ## clients/src/main/java/org/apache/kafka/common/metrics/Metrics.java: ## @@ -524,6 +527,26 @@ public void addMetric(MetricName metricName, MetricValueProvider met

[GitHub] [kafka] guozhangwang commented on a diff in pull request #12035: KAFKA-13217: Reconsider skipping the LeaveGroup on close() or add an overload that does so

2022-05-21 Thread GitBox
guozhangwang commented on code in PR #12035: URL: https://github.com/apache/kafka/pull/12035#discussion_r878743871 ## streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java: ## @@ -1498,6 +1516,61 @@ public synchronized boolean close(final Duration timeout) throws Ill

[jira] [Commented] (KAFKA-13921) Flaky test TopicCommandIntegrationTest testDescribeAtMinIsrPartitions(String).quorum=kraft

2022-05-21 Thread Divij Vaidya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17540481#comment-17540481 ] Divij Vaidya commented on KAFKA-13921: -- This is fixed in [https://github.com/apache

[jira] [Updated] (KAFKA-13921) Flaky test TopicCommandIntegrationTest testDescribeAtMinIsrPartitions(String).quorum=kraft

2022-05-21 Thread Divij Vaidya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Divij Vaidya updated KAFKA-13921: - Fix Version/s: 3.3.0 > Flaky test TopicCommandIntegrationTest > testDescribeAtMinIsrPartitions(

[jira] [Resolved] (KAFKA-13921) Flaky test TopicCommandIntegrationTest testDescribeAtMinIsrPartitions(String).quorum=kraft

2022-05-21 Thread Divij Vaidya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Divij Vaidya resolved KAFKA-13921. -- Reviewer: Jason Gustafson Resolution: Fixed > Flaky test TopicCommandIntegrationTest >

[jira] [Commented] (KAFKA-13621) Resign leader on network partition

2022-05-21 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17540486#comment-17540486 ] Guozhang Wang commented on KAFKA-13621: --- [~jagsancio] Yes I think with KIP-835 we

[GitHub] [kafka] andymg3 opened a new pull request, #12192: MINOR: Use parameterized logging in StandardAuthorizer and StandardAuthorizerData

2022-05-21 Thread GitBox
andymg3 opened a new pull request, #12192: URL: https://github.com/apache/kafka/pull/12192 This updates StandardAuthorizer and StandardAuthorizerData to use parameterized logging per the SLF4J recommendation (see https://www.slf4j.org/faq.html). This also removes a couple if statements that

[GitHub] [kafka] C0urante commented on pull request #12191: KAFKA-12657: Increase timeouts in Connect integration tests

2022-05-21 Thread GitBox
C0urante commented on PR #12191: URL: https://github.com/apache/kafka/pull/12191#issuecomment-1133779567 Looking good so far. All Connect integration tests passed in every build that was able to run them at all. Going to try to trigger another round of tests now by pushing an empty c

[GitHub] [kafka] hachikuji merged pull request #12192: MINOR: Use parameterized logging in StandardAuthorizer and StandardAuthorizerData

2022-05-21 Thread GitBox
hachikuji merged PR #12192: URL: https://github.com/apache/kafka/pull/12192 -- 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-unsubscr...@kafka.apach

[jira] [Resolved] (KAFKA-13889) Fix AclsDelta to handle ACCESS_CONTROL_ENTRY_RECORD quickly followed by REMOVE_ACCESS_CONTROL_ENTRY_RECORD for same ACL

2022-05-21 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-13889. - Fix Version/s: 3.3.0 Resolution: Fixed > Fix AclsDelta to handle ACCESS_CONTROL_E

[GitHub] [kafka] hudeqi opened a new pull request, #12193: test check

2022-05-21 Thread GitBox
hudeqi opened a new pull request, #12193: URL: https://github.com/apache/kafka/pull/12193 *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 testing