[jira] [Commented] (KAFKA-13392) Timeout Exception triggering reassign partitions with --bootstrap-server option

2021-10-25 Thread Yevgeniy Korin (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17433596#comment-17433596 ] Yevgeniy Korin commented on KAFKA-13392: [~dongjin] value for '--bootstrap-serve

[jira] [Commented] (KAFKA-13393) Update website documentation to include required arguments when creating a topic

2021-10-25 Thread Tom Bentley (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17433617#comment-17433617 ] Tom Bentley commented on KAFKA-13393: - I think this was a mistake in Kafka 3.0, see

[jira] [Commented] (KAFKA-13238) Add ActiveBrokerCount and FencedBrokerCount metrics to the KRaft controller (KIP-748)

2021-10-25 Thread David Jacot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17433627#comment-17433627 ] David Jacot commented on KAFKA-13238: - This was addressed by https://github.com/apac

[jira] [Resolved] (KAFKA-13238) Add ActiveBrokerCount and FencedBrokerCount metrics to the KRaft controller (KIP-748)

2021-10-25 Thread David Jacot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-13238. - Fix Version/s: 3.1.0 Assignee: Ryan Dielhenn Resolution: Fixed > Add ActiveBroke

[jira] [Resolved] (KAFKA-12882) Add ActiveBrokerCount and FencedBrokerCount metrics (KIP-748)

2021-10-25 Thread David Jacot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-12882. - Fix Version/s: 3.1.0 Resolution: Fixed > Add ActiveBrokerCount and FencedBrokerCount metr

[jira] [Updated] (KAFKA-12984) Cooperative sticky assignor can get stuck with invalid SubscriptionState input metadata

2021-10-25 Thread Andrei D (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrei D updated KAFKA-12984: - Attachment: image-2021-10-25-11-53-40-221.png > Cooperative sticky assignor can get stuck with invalid S

[jira] [Created] (KAFKA-13398) The caller program will be shut down directly when the execution of Kafka script is abnormal

2021-10-25 Thread RivenSun (Jira)
RivenSun created KAFKA-13398: Summary: The caller program will be shut down directly when the execution of Kafka script is abnormal Key: KAFKA-13398 URL: https://issues.apache.org/jira/browse/KAFKA-13398

[jira] [Updated] (KAFKA-13398) The caller program will be shut down directly when the execution of Kafka script is abnormal

2021-10-25 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RivenSun updated KAFKA-13398: - Description: hello [~showuon] and [~guozhang] Kafka has many key functions that have not yet been integ

[jira] [Updated] (KAFKA-13398) The caller program will be shut down directly when the execution of Kafka script is abnormal

2021-10-25 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RivenSun updated KAFKA-13398: - Description: hello [~showuon] and [~guozhang] Kafka has many key functions that have not yet been integ

[jira] [Updated] (KAFKA-13398) The caller program will be shut down directly when the execution of Kafka script is abnormal

2021-10-25 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RivenSun updated KAFKA-13398: - Description: hello [~showuon] and [~guozhang] Kafka has many key functions that have not yet been integ

[jira] [Updated] (KAFKA-13398) The caller program will be shut down directly when the execution of Kafka script is abnormal

2021-10-25 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RivenSun updated KAFKA-13398: - Description: hello [~showuon] and [~guozhang] Kafka has many key functions that have not yet been integ

[jira] [Updated] (KAFKA-13398) The caller program will be shut down directly when the execution of Kafka script is abnormal

2021-10-25 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RivenSun updated KAFKA-13398: - Description: hello [~showuon] and [~guozhang] Kafka has many key functions that have not yet been integ

[jira] [Updated] (KAFKA-13398) The caller program will be shut down directly when the execution of Kafka script is abnormal

2021-10-25 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RivenSun updated KAFKA-13398: - Description: hello [~showuon] and [~guozhang] Kafka has many key functions that have not yet been integ

[jira] [Commented] (KAFKA-12984) Cooperative sticky assignor can get stuck with invalid SubscriptionState input metadata

2021-10-25 Thread Andrei D (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17433653#comment-17433653 ] Andrei D commented on KAFKA-12984: -- The entire group used 2.8.1 Kafka-client  and 'Coop

[jira] [Updated] (KAFKA-13398) The caller program will be shut down directly when the execution of Kafka script is abnormal

2021-10-25 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RivenSun updated KAFKA-13398: - Description: hello [~showuon] and [~guozhang] Kafka has many key functions that have not yet been integ

[jira] [Updated] (KAFKA-13398) The caller program will be shut down directly when the execution of Kafka script is abnormal

2021-10-25 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RivenSun updated KAFKA-13398: - Description: hello [~showuon] and [~guozhang] Kafka has many key functions that have not yet been integ

[jira] [Updated] (KAFKA-13398) The caller program will be shut down directly when the execution of Kafka script is abnormal

2021-10-25 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RivenSun updated KAFKA-13398: - Description: hello [~showuon] and [~guozhang] Kafka has many key functions that have not yet been integ

[jira] [Updated] (KAFKA-13398) The caller program will be shut down directly when the execution of Kafka script is abnormal

2021-10-25 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RivenSun updated KAFKA-13398: - Description: hello [~showuon] and [~guozhang] Kafka has some key functions that have not yet been integ

[jira] [Updated] (KAFKA-13398) The caller program will be shut down directly when the execution of Kafka script is abnormal

2021-10-25 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RivenSun updated KAFKA-13398: - Description: hello [~showuon] and [~guozhang] Kafka has some key functions that have not yet been integ

[jira] [Updated] (KAFKA-13398) The caller program will be shut down directly when the execution of Kafka script is abnormal

2021-10-25 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RivenSun updated KAFKA-13398: - Description: hello [~showuon] and [~guozhang] Kafka has some key functions that have not yet been integ

[jira] [Updated] (KAFKA-13398) The caller program will be shut down directly when the execution of Kafka script is abnormal

2021-10-25 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RivenSun updated KAFKA-13398: - Description: hello [~showuon] and [~guozhang] Kafka has some key functions that have not yet been integ

[GitHub] [kafka] mimaison commented on pull request #11371: KAFKA-13337: fix of possible java.nio.file.AccessDeniedException during Con…

2021-10-25 Thread GitBox
mimaison commented on pull request #11371: URL: https://github.com/apache/kafka/pull/11371#issuecomment-950757901 Thanks for the PR! I played a bit locally and while Connect logs a `AccessDeniedException` exception if a file/directory is not readable, Connect seems to work fine and

[jira] [Commented] (KAFKA-13398) The caller program will be shut down directly when the execution of Kafka script is abnormal

2021-10-25 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17433672#comment-17433672 ] RivenSun commented on KAFKA-13398: -- I observed that KafkaAdminClient in Kafka-clients 3

[jira] [Comment Edited] (KAFKA-13398) The caller program will be shut down directly when the execution of Kafka script is abnormal

2021-10-25 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17433672#comment-17433672 ] RivenSun edited comment on KAFKA-13398 at 10/25/21, 10:22 AM:

[jira] [Comment Edited] (KAFKA-13398) The caller program will be shut down directly when the execution of Kafka script is abnormal

2021-10-25 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17433672#comment-17433672 ] RivenSun edited comment on KAFKA-13398 at 10/25/21, 10:26 AM:

[jira] [Comment Edited] (KAFKA-13398) The caller program will be shut down directly when the execution of Kafka script is abnormal

2021-10-25 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17433672#comment-17433672 ] RivenSun edited comment on KAFKA-13398 at 10/25/21, 10:26 AM:

[jira] [Assigned] (KAFKA-13399) Towards Scala 3: Fix constructs or syntax features not present in Scala 3

2021-10-25 Thread Josep Prat (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Josep Prat reassigned KAFKA-13399: -- Assignee: Josep Prat > Towards Scala 3: Fix constructs or syntax features not present in Scal

[jira] [Created] (KAFKA-13399) Towards Scala 3: Fix constructs or syntax features not present in Scala 3

2021-10-25 Thread Josep Prat (Jira)
Josep Prat created KAFKA-13399: -- Summary: Towards Scala 3: Fix constructs or syntax features not present in Scala 3 Key: KAFKA-13399 URL: https://issues.apache.org/jira/browse/KAFKA-13399 Project: Kafka

[jira] [Updated] (KAFKA-13398) The caller program will be shut down directly when the execution of Kafka script is abnormal

2021-10-25 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RivenSun updated KAFKA-13398: - Description: hello [~showuon] and [~guozhang] Kafka has some key functions that have not yet been integ

[jira] [Commented] (KAFKA-13398) The caller program will be shut down directly when the execution of Kafka script is abnormal

2021-10-25 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17433681#comment-17433681 ] RivenSun commented on KAFKA-13398: -- By the way, the new method *alterUserScramCredentia

[GitHub] [kafka] mimaison commented on a change in pull request #11431: KAFKA-13397: Honor 'replication.policy.separator' configuration when creating MirrorMaker2 internal topics

2021-10-25 Thread GitBox
mimaison commented on a change in pull request #11431: URL: https://github.com/apache/kafka/pull/11431#discussion_r735543104 ## File path: connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/MirrorClientConfig.java ## @@ -50,8 +50,7 @@ public static final

[jira] [Comment Edited] (KAFKA-12984) Cooperative sticky assignor can get stuck with invalid SubscriptionState input metadata

2021-10-25 Thread Andrei D (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17433653#comment-17433653 ] Andrei D edited comment on KAFKA-12984 at 10/25/21, 12:31 PM:

[jira] [Comment Edited] (KAFKA-12984) Cooperative sticky assignor can get stuck with invalid SubscriptionState input metadata

2021-10-25 Thread Andrei D (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17433653#comment-17433653 ] Andrei D edited comment on KAFKA-12984 at 10/25/21, 12:39 PM:

[jira] [Commented] (KAFKA-12984) Cooperative sticky assignor can get stuck with invalid SubscriptionState input metadata

2021-10-25 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17433747#comment-17433747 ] Luke Chen commented on KAFKA-12984: --- [~Andy_Dufresne], thanks for your response. It lo

[jira] [Assigned] (KAFKA-13337) Scanning for Connect plugins can fail with AccessDeniedException

2021-10-25 Thread Andras Katona (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andras Katona reassigned KAFKA-13337: - Assignee: Tamás Héri (was: Andras Katona) > Scanning for Connect plugins can fail with

[jira] [Updated] (KAFKA-13337) Scanning for Connect plugins can fail with AccessDeniedException

2021-10-25 Thread Andras Katona (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andras Katona updated KAFKA-13337: -- Fix Version/s: (was: 3.0.1) > Scanning for Connect plugins can fail with AccessDeniedExcep

[jira] [Updated] (KAFKA-13399) Towards Scala 3: Fix constructs or syntax features not present in Scala 3

2021-10-25 Thread Josep Prat (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Josep Prat updated KAFKA-13399: --- Description: As discussed in  [https://lists.apache.org/x/thread.html/r4ee305bef0e65e1352c358016eb40

[GitHub] [kafka] akatona84 commented on pull request #11371: KAFKA-13337: fix of possible java.nio.file.AccessDeniedException during Con…

2021-10-25 Thread GitBox
akatona84 commented on pull request #11371: URL: https://github.com/apache/kafka/pull/11371#issuecomment-950937973 @mimaison , correct, connect could work, but the plugins are not loaded. My connect stopped because an extension was supposed to be loaded and a `ConnectException` was thrown

[jira] [Updated] (KAFKA-13337) Scanning for Connect plugins can fail with AccessDeniedException

2021-10-25 Thread Andras Katona (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andras Katona updated KAFKA-13337: -- Description: During Connect plugin path scan, if an unreadable file/directory is found, Conne

[jira] [Commented] (KAFKA-13398) The caller program will be shut down directly when the execution of Kafka script is abnormal

2021-10-25 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17433767#comment-17433767 ] Luke Chen commented on KAFKA-13398: --- [~RivenSun], thanks for reporting the issue. So

[jira] [Comment Edited] (KAFKA-12984) Cooperative sticky assignor can get stuck with invalid SubscriptionState input metadata

2021-10-25 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17433747#comment-17433747 ] Luke Chen edited comment on KAFKA-12984 at 10/25/21, 2:14 PM:

[jira] [Updated] (KAFKA-13388) Kafka Producer nodes stuck in CHECKING_API_VERSIONS

2021-10-25 Thread David Hoffman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Hoffman updated KAFKA-13388: -- Attachment: Screen Shot 2021-10-25 at 10.28.48 AM.png > Kafka Producer nodes stuck in CHECKING

[jira] [Commented] (KAFKA-13388) Kafka Producer nodes stuck in CHECKING_API_VERSIONS

2021-10-25 Thread David Hoffman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17433826#comment-17433826 ] David Hoffman commented on KAFKA-13388: --- looks like the connections are getting in

[GitHub] [kafka] jlprat opened a new pull request #11432: KAFKA-13399 towards scala3

2021-10-25 Thread GitBox
jlprat opened a new pull request #11432: URL: https://github.com/apache/kafka/pull/11432 This PR takes all changes in https://github.com/apache/kafka/pull/11350 that are needed for a Scala 3 compatibility except those with an open bug report or already solved one. The PR is separate

[GitHub] [kafka] jlprat commented on a change in pull request #11432: KAFKA-13399 towards scala3

2021-10-25 Thread GitBox
jlprat commented on a change in pull request #11432: URL: https://github.com/apache/kafka/pull/11432#discussion_r735730354 ## File path: core/src/main/scala/kafka/raft/KafkaMetadataLog.scala ## @@ -42,11 +42,11 @@ final class KafkaMetadataLog private ( // Access to this obje

[GitHub] [kafka] jlprat commented on pull request #11432: KAFKA-13399 towards scala3

2021-10-25 Thread GitBox
jlprat commented on pull request #11432: URL: https://github.com/apache/kafka/pull/11432#issuecomment-951077960 cc. @ijuma if you have some time to review this I would be thankful! These are the changes I mentioned in the mailing list in regards to the Scala 3 migration. These are on

[jira] [Created] (KAFKA-13400) offset() is not supported in standby tasks.

2021-10-25 Thread prabhu biradar (Jira)
prabhu biradar created KAFKA-13400: -- Summary: offset() is not supported in standby tasks. Key: KAFKA-13400 URL: https://issues.apache.org/jira/browse/KAFKA-13400 Project: Kafka Issue Type: B

[jira] [Commented] (KAFKA-12960) WindowStore and SessionStore do not enforce strict retention time

2021-10-25 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17433856#comment-17433856 ] Matthias J. Sax commented on KAFKA-12960: - I just got a report, that `InMemoryWi

[GitHub] [kafka] vcrfxia commented on a change in pull request #11368: KAFKA-13261: Add support for custom partitioners in foreign key joins

2021-10-25 Thread GitBox
vcrfxia commented on a change in pull request #11368: URL: https://github.com/apache/kafka/pull/11368#discussion_r735763202 ## File path: streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/ForeignJoinSubscriptionProcessorSupplier.java ## @@ -69,9 +

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

2021-10-25 Thread GitBox
mjsax commented on pull request #11211: URL: https://github.com/apache/kafka/pull/11211#issuecomment-951092491 Did not look into this PR. Left the following comment on the JIRA: > I just got a report, that `InMemoryWindowStore` does not enforce strict retention for IQ if caching is e

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

2021-10-25 Thread GitBox
vamossagar12 commented on pull request #11211: URL: https://github.com/apache/kafka/pull/11211#issuecomment-951097076 > Did not look into this PR. Left the following comment on the JIRA: > > > I just got a report, that `InMemoryWindowStore` does not enforce strict retention for IQ if

[GitHub] [kafka] junrao commented on a change in pull request #11284: KAFKA-13202: KIP-768: Extend SASL/OAUTHBEARER with Support for OIDC

2021-10-25 Thread GitBox
junrao commented on a change in pull request #11284: URL: https://github.com/apache/kafka/pull/11284#discussion_r735772911 ## File path: clients/src/main/java/org/apache/kafka/common/security/oauthbearer/secured/RefreshingHttpsJwks.java ## @@ -0,0 +1,301 @@ +/* + * Licensed to

[GitHub] [kafka] vamossagar12 opened a new pull request #11433: KAFKA-13295: Avoiding Transation timeouts arising due to long restora…

2021-10-25 Thread GitBox
vamossagar12 opened a new pull request #11433: URL: https://github.com/apache/kafka/pull/11433 …tion times in EOS The PR aims to avoid transaction timeouts arising due to long restoration times of new tasks. In particular, during assignment of active tasks, if there are any open tra

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

2021-10-25 Thread GitBox
vamossagar12 commented on pull request #11433: URL: https://github.com/apache/kafka/pull/11433#issuecomment-951125230 @ableegoldman / @guozhangwang plz review this whenever you get the chance. -- This is an automated message from the Apache Git Service. To respond to the message, please l

[GitHub] [kafka] junrao merged pull request #11426: KAFKA-13391: don't fsync directory on Windows OS

2021-10-25 Thread GitBox
junrao merged pull request #11426: URL: https://github.com/apache/kafka/pull/11426 -- 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..

[jira] [Created] (KAFKA-13401) Introduce a new Interface to manage Kafka resources in MM2

2021-10-25 Thread Omnia Ibrahim (Jira)
Omnia Ibrahim created KAFKA-13401: - Summary: Introduce a new Interface to manage Kafka resources in MM2 Key: KAFKA-13401 URL: https://issues.apache.org/jira/browse/KAFKA-13401 Project: Kafka

[jira] [Assigned] (KAFKA-13401) Introduce a new Interface to manage Kafka resources in MM2

2021-10-25 Thread Omnia Ibrahim (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Omnia Ibrahim reassigned KAFKA-13401: - Assignee: Omnia Ibrahim > Introduce a new Interface to manage Kafka resources in MM2 >

[GitHub] [kafka] OmniaGM commented on a change in pull request #11431: KAFKA-13397: Honor 'replication.policy.separator' configuration when creating MirrorMaker2 internal topics

2021-10-25 Thread GitBox
OmniaGM commented on a change in pull request #11431: URL: https://github.com/apache/kafka/pull/11431#discussion_r735819464 ## File path: connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMakerConfig.java ## @@ -183,12 +187,18 @@ public MirrorClientConfig clie

[GitHub] [kafka] OmniaGM commented on a change in pull request #11431: KAFKA-13397: Honor 'replication.policy.separator' configuration when creating MirrorMaker2 internal topics

2021-10-25 Thread GitBox
OmniaGM commented on a change in pull request #11431: URL: https://github.com/apache/kafka/pull/11431#discussion_r735819464 ## File path: connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMakerConfig.java ## @@ -183,12 +187,18 @@ public MirrorClientConfig clie

[GitHub] [kafka] OmniaGM commented on a change in pull request #11431: KAFKA-13397: Honor 'replication.policy.separator' configuration when creating MirrorMaker2 internal topics

2021-10-25 Thread GitBox
OmniaGM commented on a change in pull request #11431: URL: https://github.com/apache/kafka/pull/11431#discussion_r735819464 ## File path: connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMakerConfig.java ## @@ -183,12 +187,18 @@ public MirrorClientConfig clie

[GitHub] [kafka] jlprat commented on pull request #11432: KAFKA-13399 towards scala3

2021-10-25 Thread GitBox
jlprat commented on pull request #11432: URL: https://github.com/apache/kafka/pull/11432#issuecomment-951174972 Test failure was https://issues.apache.org/jira/browse/KAFKA-4184 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Commented] (KAFKA-4184) Test failure in ReplicationQuotasTest.shouldBootstrapTwoBrokersWithFollowerThrottle

2021-10-25 Thread Josep Prat (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17433911#comment-17433911 ] Josep Prat commented on KAFKA-4184: --- Failure just happened: [https://ci-builds.apache.

[GitHub] [kafka] jolshan commented on a change in pull request #11331: KAFKA-13111: Re-evaluate Fetch Sessions when using topic IDs

2021-10-25 Thread GitBox
jolshan commented on a change in pull request #11331: URL: https://github.com/apache/kafka/pull/11331#discussion_r735854783 ## File path: core/src/main/scala/kafka/server/FetchSession.scala ## @@ -238,47 +247,40 @@ class FetchSession(val id: Int, def metadata: JFetchMetada

[GitHub] [kafka] jolshan commented on a change in pull request #11331: KAFKA-13111: Re-evaluate Fetch Sessions when using topic IDs

2021-10-25 Thread GitBox
jolshan commented on a change in pull request #11331: URL: https://github.com/apache/kafka/pull/11331#discussion_r735863741 ## File path: core/src/main/scala/kafka/server/FetchSession.scala ## @@ -238,47 +247,40 @@ class FetchSession(val id: Int, def metadata: JFetchMetada

[jira] [Commented] (KAFKA-13400) offset() is not supported in standby tasks.

2021-10-25 Thread prabhu biradar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17433929#comment-17433929 ] prabhu biradar commented on KAFKA-13400: * we use -springBootVersion = '2.1.4.RE

[GitHub] [kafka] kirktrue commented on a change in pull request #11284: KAFKA-13202: KIP-768: Extend SASL/OAUTHBEARER with Support for OIDC

2021-10-25 Thread GitBox
kirktrue commented on a change in pull request #11284: URL: https://github.com/apache/kafka/pull/11284#discussion_r735883615 ## File path: clients/src/main/java/org/apache/kafka/common/security/oauthbearer/secured/RefreshingHttpsJwks.java ## @@ -0,0 +1,301 @@ +/* + * Licensed

[GitHub] [kafka] kirktrue commented on a change in pull request #11284: KAFKA-13202: KIP-768: Extend SASL/OAUTHBEARER with Support for OIDC

2021-10-25 Thread GitBox
kirktrue commented on a change in pull request #11284: URL: https://github.com/apache/kafka/pull/11284#discussion_r735884051 ## File path: clients/src/main/java/org/apache/kafka/common/security/oauthbearer/secured/RefreshingHttpsJwks.java ## @@ -0,0 +1,301 @@ +/* + * Licensed

[GitHub] [kafka] kirktrue commented on a change in pull request #11284: KAFKA-13202: KIP-768: Extend SASL/OAUTHBEARER with Support for OIDC

2021-10-25 Thread GitBox
kirktrue commented on a change in pull request #11284: URL: https://github.com/apache/kafka/pull/11284#discussion_r735884322 ## File path: clients/src/test/java/org/apache/kafka/common/security/oauthbearer/secured/RefreshingHttpsJwksTest.java ## @@ -0,0 +1,135 @@ +/* + * Licen

[GitHub] [kafka] jeqo commented on pull request #11412: KAFKA-10543: Convert KTable joins to new PAPI

2021-10-25 Thread GitBox
jeqo commented on pull request #11412: URL: https://github.com/apache/kafka/pull/11412#issuecomment-951233343 cc @vvcephei -- 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.

[jira] [Created] (KAFKA-13402) Kafka server does not handle SIGINT or stop command if zookeeper abruptly closes/goes down

2021-10-25 Thread Gaurav (Jira)
Gaurav created KAFKA-13402: -- Summary: Kafka server does not handle SIGINT or stop command if zookeeper abruptly closes/goes down Key: KAFKA-13402 URL: https://issues.apache.org/jira/browse/KAFKA-13402 Projec

[GitHub] [kafka] kirktrue commented on a change in pull request #11284: KAFKA-13202: KIP-768: Extend SASL/OAUTHBEARER with Support for OIDC

2021-10-25 Thread GitBox
kirktrue commented on a change in pull request #11284: URL: https://github.com/apache/kafka/pull/11284#discussion_r735894744 ## File path: clients/src/main/java/org/apache/kafka/common/security/oauthbearer/secured/RefreshingHttpsJwks.java ## @@ -0,0 +1,239 @@ +/* + * Licensed

[GitHub] [kafka] kirktrue commented on a change in pull request #11284: KAFKA-13202: KIP-768: Extend SASL/OAUTHBEARER with Support for OIDC

2021-10-25 Thread GitBox
kirktrue commented on a change in pull request #11284: URL: https://github.com/apache/kafka/pull/11284#discussion_r735902362 ## File path: build.gradle ## @@ -1208,6 +1210,8 @@ project(':clients') { testRuntimeOnly libs.slf4jlog4j testRuntimeOnly libs.jacksonDatabind

[GitHub] [kafka] kirktrue commented on a change in pull request #11284: KAFKA-13202: KIP-768: Extend SASL/OAUTHBEARER with Support for OIDC

2021-10-25 Thread GitBox
kirktrue commented on a change in pull request #11284: URL: https://github.com/apache/kafka/pull/11284#discussion_r735902697 ## File path: build.gradle ## @@ -1604,6 +1608,7 @@ project(':tools') { implementation libs.slf4jApi implementation libs.log4j +implement

[GitHub] [kafka] jolshan commented on a change in pull request #11331: KAFKA-13111: Re-evaluate Fetch Sessions when using topic IDs

2021-10-25 Thread GitBox
jolshan commented on a change in pull request #11331: URL: https://github.com/apache/kafka/pull/11331#discussion_r735935021 ## File path: clients/src/main/java/org/apache/kafka/clients/FetchSessionHandler.java ## @@ -285,52 +268,57 @@ public FetchRequestData build() {

[GitHub] [kafka] jolshan commented on a change in pull request #11331: KAFKA-13111: Re-evaluate Fetch Sessions when using topic IDs

2021-10-25 Thread GitBox
jolshan commented on a change in pull request #11331: URL: https://github.com/apache/kafka/pull/11331#discussion_r735935021 ## File path: clients/src/main/java/org/apache/kafka/clients/FetchSessionHandler.java ## @@ -285,52 +268,57 @@ public FetchRequestData build() {

[GitHub] [kafka] junrao commented on a change in pull request #11284: KAFKA-13202: KIP-768: Extend SASL/OAUTHBEARER with Support for OIDC

2021-10-25 Thread GitBox
junrao commented on a change in pull request #11284: URL: https://github.com/apache/kafka/pull/11284#discussion_r735929417 ## File path: clients/src/main/java/org/apache/kafka/common/security/oauthbearer/secured/RefreshingHttpsJwks.java ## @@ -0,0 +1,298 @@ +/* + * Licensed to

[GitHub] [kafka] soarez commented on a change in pull request #11417: KAFKA-13340: Change ZooKeeperTestHarness to QuorumTestHarness

2021-10-25 Thread GitBox
soarez commented on a change in pull request #11417: URL: https://github.com/apache/kafka/pull/11417#discussion_r735951119 ## File path: core/src/test/scala/kafka/utils/TestInfoUtils.scala ## @@ -0,0 +1,46 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one o

[GitHub] [kafka] kirktrue commented on a change in pull request #11284: KAFKA-13202: KIP-768: Extend SASL/OAUTHBEARER with Support for OIDC

2021-10-25 Thread GitBox
kirktrue commented on a change in pull request #11284: URL: https://github.com/apache/kafka/pull/11284#discussion_r735980753 ## File path: clients/src/main/java/org/apache/kafka/common/security/oauthbearer/secured/RefreshingHttpsJwks.java ## @@ -0,0 +1,298 @@ +/* + * Licensed

[GitHub] [kafka] kirktrue commented on a change in pull request #11284: KAFKA-13202: KIP-768: Extend SASL/OAUTHBEARER with Support for OIDC

2021-10-25 Thread GitBox
kirktrue commented on a change in pull request #11284: URL: https://github.com/apache/kafka/pull/11284#discussion_r735981362 ## File path: clients/src/main/java/org/apache/kafka/common/security/oauthbearer/secured/RefreshingHttpsJwks.java ## @@ -0,0 +1,298 @@ +/* + * Licensed

[jira] [Commented] (KAFKA-13388) Kafka Producer nodes stuck in CHECKING_API_VERSIONS

2021-10-25 Thread David Hoffman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17433992#comment-17433992 ] David Hoffman commented on KAFKA-13388: --- I'm going to try enabling debug logging f

[GitHub] [kafka] FlorianLehmann closed pull request #11425: KAFKA-13393 Documentation - Add missing arguments to create a topic

2021-10-25 Thread GitBox
FlorianLehmann closed pull request #11425: URL: https://github.com/apache/kafka/pull/11425 -- 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-un

[GitHub] [kafka] kirktrue commented on a change in pull request #11284: KAFKA-13202: KIP-768: Extend SASL/OAUTHBEARER with Support for OIDC

2021-10-25 Thread GitBox
kirktrue commented on a change in pull request #11284: URL: https://github.com/apache/kafka/pull/11284#discussion_r736006401 ## File path: clients/src/main/java/org/apache/kafka/common/security/oauthbearer/secured/RefreshingHttpsJwks.java ## @@ -0,0 +1,298 @@ +/* + * Licensed

[GitHub] [kafka] kirktrue commented on a change in pull request #11284: KAFKA-13202: KIP-768: Extend SASL/OAUTHBEARER with Support for OIDC

2021-10-25 Thread GitBox
kirktrue commented on a change in pull request #11284: URL: https://github.com/apache/kafka/pull/11284#discussion_r736009184 ## File path: clients/src/main/java/org/apache/kafka/common/security/oauthbearer/secured/RefreshingHttpsJwks.java ## @@ -0,0 +1,298 @@ +/* + * Licensed

[GitHub] [kafka] kirktrue commented on a change in pull request #11284: KAFKA-13202: KIP-768: Extend SASL/OAUTHBEARER with Support for OIDC

2021-10-25 Thread GitBox
kirktrue commented on a change in pull request #11284: URL: https://github.com/apache/kafka/pull/11284#discussion_r736016076 ## File path: clients/src/main/java/org/apache/kafka/common/security/oauthbearer/secured/RefreshingHttpsJwks.java ## @@ -0,0 +1,298 @@ +/* + * Licensed

[GitHub] [kafka] hachikuji commented on a change in pull request #11417: KAFKA-13340: Change ZooKeeperTestHarness to QuorumTestHarness

2021-10-25 Thread GitBox
hachikuji commented on a change in pull request #11417: URL: https://github.com/apache/kafka/pull/11417#discussion_r736025333 ## File path: core/src/test/scala/integration/kafka/server/QuorumTestHarness.scala ## @@ -0,0 +1,339 @@ +/** + * Licensed to the Apache Software Foundat

[GitHub] [kafka] kirktrue commented on a change in pull request #11284: KAFKA-13202: KIP-768: Extend SASL/OAUTHBEARER with Support for OIDC

2021-10-25 Thread GitBox
kirktrue commented on a change in pull request #11284: URL: https://github.com/apache/kafka/pull/11284#discussion_r736041929 ## File path: clients/src/main/java/org/apache/kafka/common/security/oauthbearer/secured/RefreshingHttpsJwks.java ## @@ -0,0 +1,298 @@ +/* + * Licensed

[jira] [Commented] (KAFKA-12960) WindowStore and SessionStore do not enforce strict retention time

2021-10-25 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434056#comment-17434056 ] A. Sophie Blee-Goldman commented on KAFKA-12960: [~mjsax] sounds like th

[jira] [Commented] (KAFKA-12960) WindowStore and SessionStore do not enforce strict retention time

2021-10-25 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434066#comment-17434066 ] Matthias J. Sax commented on KAFKA-12960: - Yes, but if we move the check into Me

[jira] [Created] (KAFKA-13403) KafkaServer crashes when deleting topics due to the race in log deletion

2021-10-25 Thread Haruki Okada (Jira)
Haruki Okada created KAFKA-13403: Summary: KafkaServer crashes when deleting topics due to the race in log deletion Key: KAFKA-13403 URL: https://issues.apache.org/jira/browse/KAFKA-13403 Project: Kaf

[jira] [Commented] (KAFKA-12960) WindowStore and SessionStore do not enforce strict retention time

2021-10-25 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434073#comment-17434073 ] A. Sophie Blee-Goldman commented on KAFKA-12960: Oh yeah I agree, I was

[jira] [Updated] (KAFKA-13403) KafkaServer crashes when deleting topics due to the race in log deletion

2021-10-25 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada updated KAFKA-13403: - Description: h2. Environment * OS: CentOS Linux release 7.6 * Kafka version: 2.4.1 * ** Bu

[jira] [Commented] (KAFKA-12960) WindowStore and SessionStore do not enforce strict retention time

2021-10-25 Thread Sagar Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434075#comment-17434075 ] Sagar Rao commented on KAFKA-12960: --- That’s something which the pr already addresses f

[jira] [Commented] (KAFKA-13398) The caller program will be shut down directly when the execution of Kafka script is abnormal

2021-10-25 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434074#comment-17434074 ] RivenSun commented on KAFKA-13398: -- [~showuon] Thanks for your reply. Thank you for th

[jira] [Comment Edited] (KAFKA-13398) The caller program will be shut down directly when the execution of Kafka script is abnormal

2021-10-25 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434074#comment-17434074 ] RivenSun edited comment on KAFKA-13398 at 10/26/21, 2:51 AM: -

[jira] [Comment Edited] (KAFKA-13398) The caller program will be shut down directly when the execution of Kafka script is abnormal

2021-10-25 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434074#comment-17434074 ] RivenSun edited comment on KAFKA-13398 at 10/26/21, 2:52 AM: -

[jira] [Comment Edited] (KAFKA-13398) The caller program will be shut down directly when the execution of Kafka script is abnormal

2021-10-25 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434074#comment-17434074 ] RivenSun edited comment on KAFKA-13398 at 10/26/21, 2:52 AM: -

[jira] [Comment Edited] (KAFKA-13398) The caller program will be shut down directly when the execution of Kafka script is abnormal

2021-10-25 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434074#comment-17434074 ] RivenSun edited comment on KAFKA-13398 at 10/26/21, 2:53 AM: -

[jira] [Comment Edited] (KAFKA-13398) The caller program will be shut down directly when the execution of Kafka script is abnormal

2021-10-25 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434074#comment-17434074 ] RivenSun edited comment on KAFKA-13398 at 10/26/21, 2:53 AM: -

[jira] [Comment Edited] (KAFKA-13398) The caller program will be shut down directly when the execution of Kafka script is abnormal

2021-10-25 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434074#comment-17434074 ] RivenSun edited comment on KAFKA-13398 at 10/26/21, 2:54 AM: -

[GitHub] [kafka] showuon commented on a change in pull request #11430: KAFKA-13352: Kafka Client does not support passwords starting with number in jaas config

2021-10-25 Thread GitBox
showuon commented on a change in pull request #11430: URL: https://github.com/apache/kafka/pull/11430#discussion_r736150581 ## File path: clients/src/main/java/org/apache/kafka/common/security/JaasConfig.java ## @@ -50,12 +50,24 @@ private final List configEntries;

  1   2   >