[jira] [Comment Edited] (KAFKA-13578) Need clarity on the bridge release version of kafka without zookeeper in the eco system - KIP500

2022-01-06 Thread kaushik srinivas (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17470385#comment-17470385 ] kaushik srinivas edited comment on KAFKA-13578 at 1/7/22, 7:25 AM: ---

[jira] [Commented] (KAFKA-13578) Need clarity on the bridge release version of kafka without zookeeper in the eco system - KIP500

2022-01-06 Thread kaushik srinivas (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17470385#comment-17470385 ] kaushik srinivas commented on KAFKA-13578: -- [~ijuma]  Can you provide some ins

[jira] [Created] (KAFKA-13578) Need clarity on the bridge release version of kafka without zookeeper in the eco system - KIP500

2022-01-06 Thread kaushik srinivas (Jira)
kaushik srinivas created KAFKA-13578: Summary: Need clarity on the bridge release version of kafka without zookeeper in the eco system - KIP500 Key: KAFKA-13578 URL: https://issues.apache.org/jira/browse/KAFKA

[jira] [Commented] (KAFKA-12616) Convert integration tests to use ClusterTest

2022-01-06 Thread dengziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17470362#comment-17470362 ] dengziming commented on KAFKA-12616: It seems we can use QuorumTestHarness to test b

[GitHub] [kafka] dengziming commented on a change in pull request #11634: MINOR: enable KRaft in TopicCommandIntegrationTest

2022-01-06 Thread GitBox
dengziming commented on a change in pull request #11634: URL: https://github.com/apache/kafka/pull/11634#discussion_r780047401 ## File path: core/src/test/scala/unit/kafka/admin/TopicCommandIntegrationTest.scala ## @@ -443,25 +486,30 @@ class TopicCommandIntegrationTest extend

[GitHub] [kafka] ahmed3465 edited a comment on pull request #6097: KAFKA-5061 - Make default Worker Task client IDs distinct

2022-01-06 Thread GitBox
ahmed3465 edited a comment on pull request #6097: URL: https://github.com/apache/kafka/pull/6097#issuecomment-1007159144 Is there a way I can alter the code and share the Mbean sensor across multiple consumers using the same client-id ? We have an auto-scaling Kafka connect cluster which

[GitHub] [kafka] ahmed3465 edited a comment on pull request #6097: KAFKA-5061 - Make default Worker Task client IDs distinct

2022-01-06 Thread GitBox
ahmed3465 edited a comment on pull request #6097: URL: https://github.com/apache/kafka/pull/6097#issuecomment-1007159144 Is there a way to share the Mbean sensor across multiple consumers using the same client-id ? We have an auto-scaling Kafka connect cluster which uses client and user

[GitHub] [kafka] ahmed3465 commented on pull request #6097: KAFKA-5061 - Make default Worker Task client IDs distinct

2022-01-06 Thread GitBox
ahmed3465 commented on pull request #6097: URL: https://github.com/apache/kafka/pull/6097#issuecomment-1007159144 Is there a way to share the Mbean sensor across multiple consumers using the same client-id ? We have an auto-scaling Kafka connect cluster which uses client and user quotas

[GitHub] [kafka] Abhijit-Mane closed pull request #10782: Fix issue with 'UID' string in Dockerfile used for System Test

2022-01-06 Thread GitBox
Abhijit-Mane closed pull request #10782: URL: https://github.com/apache/kafka/pull/10782 -- 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-unsu

[GitHub] [kafka] Abhijit-Mane commented on pull request #10782: Fix issue with 'UID' string in Dockerfile used for System Test

2022-01-06 Thread GitBox
Abhijit-Mane commented on pull request #10782: URL: https://github.com/apache/kafka/pull/10782#issuecomment-1007150259 Closing issue, details in https://issues.apache.org/jira/browse/KAFKA-12847 -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [kafka] dengziming commented on pull request #11655: KAFKA-13316; Enable KRaft mode in CreateTopics tests

2022-01-06 Thread GitBox
dengziming commented on pull request #11655: URL: https://github.com/apache/kafka/pull/11655#issuecomment-1007141611 Hello @cmccabe , Please help review this, thank you. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [kafka] dengziming opened a new pull request #11655: KAFKA-13316; Enable KRaft mode in CreateTopics tests

2022-01-06 Thread GitBox
dengziming opened a new pull request #11655: URL: https://github.com/apache/kafka/pull/11655 *More detailed description of your change* This PR follows #11629 to enable `CreateTopicsRequestWithForwardingTest` and `CreateTopicsRequestWithPolicyTest` in KRaft mode. *Summary of testi

[GitHub] [kafka] cmccabe merged pull request #11633: MINOR: support KRaft in TransactionsExpirationTest

2022-01-06 Thread GitBox
cmccabe merged pull request #11633: URL: https://github.com/apache/kafka/pull/11633 -- 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.

[GitHub] [kafka] cmccabe commented on pull request #11633: MINOR: support KRaft in TransactionsExpirationTest

2022-01-06 Thread GitBox
cmccabe commented on pull request #11633: URL: https://github.com/apache/kafka/pull/11633#issuecomment-1006993814 Thanks for the review, @jsancio ! > LGTM @cmccabe . Should we always provide a description for the commit? If so, can you please include a description? I think thi

[GitHub] [kafka] cmccabe commented on pull request #11634: MINOR: enable KRaft in TopicCommandIntegrationTest

2022-01-06 Thread GitBox
cmccabe commented on pull request #11634: URL: https://github.com/apache/kafka/pull/11634#issuecomment-1006991927 I fixed some pre-existing race conditions in the tests, related to metadata propagation. -- This is an automated message from the Apache Git Service. To respond to the messag

[GitHub] [kafka] cmccabe commented on pull request #11640: MINOR: enable KRaft on ListConsumerGroupTest

2022-01-06 Thread GitBox
cmccabe commented on pull request #11640: URL: https://github.com/apache/kafka/pull/11640#issuecomment-1006980868 Test failures are not related. They are `kafka.controller.ControllerIntegrationTest.testTopicIdCreatedOnUpgrade` (a test for the old controller), and `EosIntegrationTest.shoul

[GitHub] [kafka] cmccabe edited a comment on pull request #11639: MINOR: enable KRaft in EndToEndClusterIdTest

2022-01-06 Thread GitBox
cmccabe edited a comment on pull request #11639: URL: https://github.com/apache/kafka/pull/11639#issuecomment-1006976419 Weird error from Jenkins: ``` [2022-01-02T08:54:28.118Z] The recommended git tool is: git Resume after a restart not supported for non-blocking synchronou

[GitHub] [kafka] cmccabe commented on pull request #11639: MINOR: enable KRaft in EndToEndClusterIdTest

2022-01-06 Thread GitBox
cmccabe commented on pull request #11639: URL: https://github.com/apache/kafka/pull/11639#issuecomment-1006976419 Weird error from Jenkins: ``` [2022-01-02T08:54:28.118Z] The recommended git tool is: git Resume after a restart not supported for non-blocking synchronous steps

[GitHub] [kafka] cmccabe commented on pull request #11638: MINOR: enable KRaft in DeleteTopicsRequestTest

2022-01-06 Thread GitBox
cmccabe commented on pull request #11638: URL: https://github.com/apache/kafka/pull/11638#issuecomment-1006975655 Rebased -- 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. T

[GitHub] [kafka] cmccabe commented on pull request #11636: MINOR: enable KRaft in LogOffsetTest

2022-01-06 Thread GitBox
cmccabe commented on pull request #11636: URL: https://github.com/apache/kafka/pull/11636#issuecomment-1006967605 Rebased -- 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. T

[GitHub] [kafka] cmccabe merged pull request #11635: MINOR: enable KRaft in MinIsrConfigTest

2022-01-06 Thread GitBox
cmccabe merged pull request #11635: URL: https://github.com/apache/kafka/pull/11635 -- 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.

[GitHub] [kafka] cmccabe commented on pull request #11635: MINOR: enable KRaft in MinIsrConfigTest

2022-01-06 Thread GitBox
cmccabe commented on pull request #11635: URL: https://github.com/apache/kafka/pull/11635#issuecomment-1006965338 Thanks for the review, @jsancio . > LGTM @cmccabe . Should we always provide a description for the commit? If so, can you please include a description? If the desc

[GitHub] [kafka] ewencp commented on pull request #10056: KAFKA-12293: remove JCenter and Bintray repositories mentions out of build gradle scripts (sunset is announced for those repositories)

2022-01-06 Thread GitBox
ewencp commented on pull request #10056: URL: https://github.com/apache/kafka/pull/10056#issuecomment-1006954861 @mdshadabin as mentioned by @ijuma above, this hasn't been backported to older releases yet. Unit tests are sometimes flaky, so might just be due to that. At this point it would

[GitHub] [kafka] ccding commented on pull request #11345: Allow empty last segment to have missing offset index during recovery

2022-01-06 Thread GitBox
ccding commented on pull request #11345: URL: https://github.com/apache/kafka/pull/11345#issuecomment-1006930874 ping @kowshik @junrao @hachikuji -- 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

[GitHub] [kafka] diegoazevedo commented on pull request #7898: KAFKA-9366: Change log4j dependency into log4j2

2022-01-06 Thread GitBox
diegoazevedo commented on pull request #7898: URL: https://github.com/apache/kafka/pull/7898#issuecomment-1006920498 Just for information, the use of an obsolete version of log4j is now seen as a critical vulnerability for some security scanners. We received this "Critical Warning" from Te

[GitHub] [kafka] vbsiegem commented on pull request #7898: KAFKA-9366: Change log4j dependency into log4j2

2022-01-06 Thread GitBox
vbsiegem commented on pull request #7898: URL: https://github.com/apache/kafka/pull/7898#issuecomment-1006913721 Are there any firm plans at this time for when log4j v2 support in Kafka will be released, and in what release(s)? -- This is an automated message from the Apache Git Service.

[GitHub] [kafka] guozhangwang merged pull request #11652: MINOR: Add num threads logging upon shutdown

2022-01-06 Thread GitBox
guozhangwang merged pull request #11652: URL: https://github.com/apache/kafka/pull/11652 -- 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-unsu

[GitHub] [kafka] cmccabe merged pull request #11593: KAFKA-13528: KRaft RegisterBroker should validate that the cluster ID matches

2022-01-06 Thread GitBox
cmccabe merged pull request #11593: URL: https://github.com/apache/kafka/pull/11593 -- 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.

[GitHub] [kafka] cmccabe commented on pull request #11593: KAFKA-13528: KRaft RegisterBroker should validate that the cluster ID matches

2022-01-06 Thread GitBox
cmccabe commented on pull request #11593: URL: https://github.com/apache/kafka/pull/11593#issuecomment-1006801028 > Should we add an integration that shows the expected behavior on the broker side? It would be a difficult integration test to write, since the existing test framework

[GitHub] [kafka] cmccabe merged pull request #11629: MINOR: enable KRaft mode in CreateTopicsRequestTest

2022-01-06 Thread GitBox
cmccabe merged pull request #11629: URL: https://github.com/apache/kafka/pull/11629 -- 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.

[GitHub] [kafka] cmccabe commented on pull request #11629: MINOR: enable KRaft mode in CreateTopicsRequestTest

2022-01-06 Thread GitBox
cmccabe commented on pull request #11629: URL: https://github.com/apache/kafka/pull/11629#issuecomment-1006797056 Test failures are not related. Comitting. -- 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

[GitHub] [kafka] cmccabe commented on pull request #11629: MINOR: enable KRaft mode in CreateTopicsRequestTest

2022-01-06 Thread GitBox
cmccabe commented on pull request #11629: URL: https://github.com/apache/kafka/pull/11629#issuecomment-1006796926 Thanks @hachikuji. Thanks @dengziming for finding a race condition in the test, which is fixed now! -- This is an automated message from the Apache Git Service. To respond to

[GitHub] [kafka] cmccabe commented on a change in pull request #11629: MINOR: enable KRaft mode in CreateTopicsRequestTest

2022-01-06 Thread GitBox
cmccabe commented on a change in pull request #11629: URL: https://github.com/apache/kafka/pull/11629#discussion_r779746531 ## File path: core/src/test/scala/unit/kafka/server/AbstractCreateTopicsRequestTest.scala ## @@ -136,11 +144,13 @@ abstract class AbstractCreateTopicsReq

[GitHub] [kafka] vamossagar12 commented on pull request #11211: KAFKA-12960: Enforcing strict retention time for WindowStore and Sess…

2022-01-06 Thread GitBox
vamossagar12 commented on pull request #11211: URL: https://github.com/apache/kafka/pull/11211#issuecomment-1006768109 > > @mjsax @ableegoldman could you chime in here? > > @guozhangwang could we also decide upon the next steps here? @guozhangwang / @ableegoldman any suggestio

[GitHub] [kafka] vamossagar12 commented on a change in pull request #11433: KAFKA-13295: Avoiding Transation timeouts arising due to long restora…

2022-01-06 Thread GitBox
vamossagar12 commented on a change in pull request #11433: URL: https://github.com/apache/kafka/pull/11433#discussion_r779716364 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java ## @@ -292,12 +327,20 @@ public void handleAssignm

[GitHub] [kafka] vamossagar12 commented on pull request #11424: KAFKA-13152: Replace "buffered.records.per.partition" with "input.buffer.max.bytes"

2022-01-06 Thread GitBox
vamossagar12 commented on pull request #11424: URL: https://github.com/apache/kafka/pull/11424#issuecomment-1006767050 > hey @guozhangwang , For `CACHE_MAX_BYTES_BUFFERING_CONFIG` , I can replace but as per one of the comments here => [#11424 (comment)](https://github.com/apache/kafka/pull

[GitHub] [kafka] ispringer commented on a change in pull request #7898: KAFKA-9366: Change log4j dependency into log4j2

2022-01-06 Thread GitBox
ispringer commented on a change in pull request #7898: URL: https://github.com/apache/kafka/pull/7898#discussion_r779703586 ## File path: gradle/dependencies.gradle ## @@ -75,6 +75,7 @@ versions += [ jmh: "1.32", hamcrest: "2.2", log4j: "1.2.17", + log4j2: "2.17.0",

[GitHub] [kafka] tyamashi-oss commented on pull request #10644: [KAFKA-12635] auto sync consumer offset 0 when translated offset larger than partition end offset

2022-01-06 Thread GitBox
tyamashi-oss commented on pull request #10644: URL: https://github.com/apache/kafka/pull/10644#issuecomment-1006638780 I'm having a similar problem. I was looking for a solution to my problem and found here. Please forgive me for expressing my personal opinion and sharing my similar proble

[GitHub] [kafka] gurinderu closed pull request #11654: KAFKA-4090: Validate SSL connection in client

2022-01-06 Thread GitBox
gurinderu closed pull request #11654: URL: https://github.com/apache/kafka/pull/11654 -- 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-unsubsc

[GitHub] [kafka] gurinderu opened a new pull request #11654: KAFKA-4090: Validate SSL connection in client

2022-01-06 Thread GitBox
gurinderu opened a new pull request #11654: URL: https://github.com/apache/kafka/pull/11654 This fix is a copy-paste from https://github.com/apache/kafka/pull/8066 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the U

[jira] [Assigned] (KAFKA-13577) Replace EasyMock and PowerMock with Mockito in core module

2022-01-06 Thread Mickael Maison (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison reassigned KAFKA-13577: -- Assignee: Mickael Maison > Replace EasyMock and PowerMock with Mockito in core module

[jira] [Created] (KAFKA-13577) Replace EasyMock and PowerMock with Mockito in core module

2022-01-06 Thread Mickael Maison (Jira)
Mickael Maison created KAFKA-13577: -- Summary: Replace EasyMock and PowerMock with Mockito in core module Key: KAFKA-13577 URL: https://issues.apache.org/jira/browse/KAFKA-13577 Project: Kafka

[GitHub] [kafka] rajinisivaram merged pull request #11653: MINOR: improve test runtime by unblocking purgatory and quota manager threads

2022-01-06 Thread GitBox
rajinisivaram merged pull request #11653: URL: https://github.com/apache/kafka/pull/11653 -- 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-uns

[GitHub] [kafka] dengziming commented on a change in pull request #11629: MINOR: enable KRaft mode in CreateTopicsRequestTest

2022-01-06 Thread GitBox
dengziming commented on a change in pull request #11629: URL: https://github.com/apache/kafka/pull/11629#discussion_r779380315 ## File path: core/src/test/scala/unit/kafka/server/AbstractCreateTopicsRequestTest.scala ## @@ -136,11 +144,13 @@ abstract class AbstractCreateTopics