[GitHub] [kafka] JoeCqupt commented on pull request #11427: MINOR: fix partition state change error msg

2021-10-26 Thread GitBox
JoeCqupt commented on pull request #11427: URL: https://github.com/apache/kafka/pull/11427#issuecomment-952564114 Call for review @dajac -- 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

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

2021-10-26 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434669#comment-17434669 ] Luke Chen commented on KAFKA-12984: --- Yes, I'm going to create another Jira issue for it. Will work on

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

2021-10-26 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434666#comment-17434666 ] A. Sophie Blee-Goldman commented on KAFKA-12984: [~showuon] want to prepare a quick fix

[GitHub] [kafka] showuon commented on pull request #11413: KAFKA-13370: add errors when commit offsets failed and add tests

2021-10-26 Thread GitBox
showuon commented on pull request #11413: URL: https://github.com/apache/kafka/pull/11413#issuecomment-952499102 @UnityLung @chia7712 @rhauch , please help review this PR when available. Thank you. -- This is an automated message from the Apache Git Service. To respond to the message,

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

2021-10-26 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434645#comment-17434645 ] Luke Chen commented on KAFKA-13403: --- [~arunmathew88], I can't, either. I think it's because you don't

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

2021-10-26 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-13403: - Assignee: Haruki Okada > KafkaServer crashes when deleting topics due to the race in log

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

2021-10-26 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-13403: - Assignee: (was: Haruki Okada) > KafkaServer crashes when deleting topics due to the race

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

2021-10-26 Thread Arun Mathew (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434641#comment-17434641 ] Arun Mathew commented on KAFKA-13403: - Hello [~showuon], I am a colleague of [~ocadaruma]. We have

[GitHub] [kafka] arunmathew88 opened a new pull request #11438: KAFKA-13403 Fix KafkaServer crashes when deleting topics due to the race in log deletion

2021-10-26 Thread GitBox
arunmathew88 opened a new pull request #11438: URL: https://github.com/apache/kafka/pull/11438 *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

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

2021-10-26 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434635#comment-17434635 ] RivenSun commented on KAFKA-13398: -- [~tombentley]  Thank you for your suggestion, this KafkaAPIs wiki

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

2021-10-26 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada reassigned KAFKA-13403: Assignee: Haruki Okada > KafkaServer crashes when deleting topics due to the race in log

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

2021-10-26 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada reassigned KAFKA-13403: Assignee: (was: Haruki Okada) > KafkaServer crashes when deleting topics due to the

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

2021-10-26 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434631#comment-17434631 ] Luke Chen commented on KAFKA-13403: --- [~ocadaruma], go ahead to take over. I thought you are not

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

2021-10-26 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-13403: - Assignee: Haruki Okada (was: Luke Chen) > KafkaServer crashes when deleting topics due to the

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

2021-10-26 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434630#comment-17434630 ] Haruki Okada edited comment on KAFKA-13403 at 10/27/21, 1:49 AM: -

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

2021-10-26 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434630#comment-17434630 ] Haruki Okada commented on KAFKA-13403: -- [~showuon] Already working on it? or may I. > KafkaServer

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

2021-10-26 Thread GitBox
ableegoldman commented on a change in pull request #11433: URL: https://github.com/apache/kafka/pull/11433#discussion_r737016054 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java ## @@ -280,6 +328,13 @@ public void

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

2021-10-26 Thread GitBox
jolshan edited a comment on pull request #11331: URL: https://github.com/apache/kafka/pull/11331#issuecomment-949274575 TODOs: 1. ~Change inconsistent topic ID so it is no longer a top level error~ 2. ~Maybe refactor some of the receiving side code, we have a map with

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

2021-10-26 Thread GitBox
kirktrue commented on a change in pull request #11284: URL: https://github.com/apache/kafka/pull/11284#discussion_r736971828 ## File path: clients/src/main/java/org/apache/kafka/common/security/oauthbearer/secured/RefreshingHttpsJwks.java ## @@ -0,0 +1,328 @@ +/* + * 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-26 Thread GitBox
kirktrue commented on a change in pull request #11284: URL: https://github.com/apache/kafka/pull/11284#discussion_r736970385 ## File path: clients/src/main/java/org/apache/kafka/common/security/oauthbearer/secured/OAuthBearerValidatorCallbackHandler.java ## @@ -0,0 +1,283 @@

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

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

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

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

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

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

[GitHub] [kafka] cmccabe merged pull request #11437: MINOR: fix the path metadata shell uses for client quotas

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

[GitHub] [kafka] cmccabe edited a comment on pull request #11417: KAFKA-13340: Change ZooKeeperTestHarness to QuorumTestHarness

2021-10-26 Thread GitBox
cmccabe edited a comment on pull request #11417: URL: https://github.com/apache/kafka/pull/11417#issuecomment-952366646 > The patch seems ok. I confess it's not obvious to me what this approach buys us over the use of ClusterTestExtensions. Seems like another way we could do this is to

[GitHub] [kafka] cmccabe commented on pull request #11417: KAFKA-13340: Change ZooKeeperTestHarness to QuorumTestHarness

2021-10-26 Thread GitBox
cmccabe commented on pull request #11417: URL: https://github.com/apache/kafka/pull/11417#issuecomment-952366646 > The patch seems ok. I confess it's not obvious to me what this approach buys us over the use of ClusterTestExtensions. Seems like another way we could do this is to let

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

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

[GitHub] [kafka] cmccabe merged pull request #11028: MINOR: Use /tmp/kraft-controller-logs for the example controller logs

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

[GitHub] [kafka] cmccabe commented on pull request #11028: MINOR: Use /tmp/kraft-controller-logs for the example controller logs

2021-10-26 Thread GitBox
cmccabe commented on pull request #11028: URL: https://github.com/apache/kafka/pull/11028#issuecomment-952342421 Seems reasonable. Thanks, @tombentley . -- 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 #10830: KAFKA-12902: Add unit32 type in generator

2021-10-26 Thread GitBox
cmccabe commented on pull request #10830: URL: https://github.com/apache/kafka/pull/10830#issuecomment-952338663 I left a comment. LGTM aside from that. Thanks, @dengziming . -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [kafka] cmccabe commented on a change in pull request #10830: KAFKA-12902: Add unit32 type in generator

2021-10-26 Thread GitBox
cmccabe commented on a change in pull request #10830: URL: https://github.com/apache/kafka/pull/10830#discussion_r736932247 ## File path: clients/src/main/java/org/apache/kafka/common/protocol/MessageUtil.java ## @@ -94,6 +94,15 @@ public static int

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

2021-10-26 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434579#comment-17434579 ] A. Sophie Blee-Goldman commented on KAFKA-12984: Mm, yeah, I should've remembered that

[GitHub] [kafka] cmccabe closed pull request #10956: MINOR: fix ZkMetadataCache package name

2021-10-26 Thread GitBox
cmccabe closed pull request #10956: URL: https://github.com/apache/kafka/pull/10956 -- 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:

[GitHub] [kafka] cmccabe commented on pull request #10956: MINOR: fix ZkMetadataCache package name

2021-10-26 Thread GitBox
cmccabe commented on pull request #10956: URL: https://github.com/apache/kafka/pull/10956#issuecomment-952334166 committed -- 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.

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

2021-10-26 Thread GitBox
guozhangwang commented on pull request #11368: URL: https://github.com/apache/kafka/pull/11368#issuecomment-952326762 I made another pass on the PR, LGTM. Also there are successful runs from jenkins too. @mjsax please feel free to merge it after your final pass. -- This is an automated

[GitHub] [kafka] hachikuji commented on a change in pull request #11437: MINOR: fix the path metadata shell uses for client quotas

2021-10-26 Thread GitBox
hachikuji commented on a change in pull request #11437: URL: https://github.com/apache/kafka/pull/11437#discussion_r736921796 ## File path: shell/src/test/java/org/apache/kafka/shell/MetadataNodeManagerTest.java ## @@ -264,16 +264,30 @@ public void testClientQuotaRecord() {

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

2021-10-26 Thread GitBox
guozhangwang commented on a change in pull request #11368: URL: https://github.com/apache/kafka/pull/11368#discussion_r736921585 ## File path: streams/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyInnerJoinCustomPartitionerIntegrationTest.java ## @@

[jira] [Resolved] (KAFKA-10800) Validate the snapshot id when the state machine creates a snapshot

2021-10-26 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-10800. - Resolution: Fixed > Validate the snapshot id when the state machine creates a snapshot

[GitHub] [kafka] hachikuji merged pull request #10593: KAFKA-10800 Enhance the test for validation when the state machine creates a snapshot

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

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

2021-10-26 Thread GitBox
junrao commented on a change in pull request #11284: URL: https://github.com/apache/kafka/pull/11284#discussion_r736894948 ## File path: clients/src/main/java/org/apache/kafka/common/security/oauthbearer/secured/OAuthBearerValidatorCallbackHandler.java ## @@ -0,0 +1,283 @@

[GitHub] [kafka] cmccabe edited a comment on pull request #11339: MINOR: ClientQuotaRecord is not handled in KRaft MetadataShell

2021-10-26 Thread GitBox
cmccabe edited a comment on pull request #11339: URL: https://github.com/apache/kafka/pull/11339#issuecomment-952318773 I filed https://github.com/apache/kafka/pull/11437 to fix up the path that we're using. These shouldn't actually be in the config directory (because they're not configs)

[GitHub] [kafka] cmccabe commented on pull request #11339: MINOR: ClientQuotaRecord is not handled in KRaft MetadataShell

2021-10-26 Thread GitBox
cmccabe commented on pull request #11339: URL: https://github.com/apache/kafka/pull/11339#issuecomment-952318773 I followed https://github.com/apache/kafka/pull/11437 to fix up the path that we're using. These shouldn't actually be in the config directory (because they're not configs)

[GitHub] [kafka] ableegoldman opened a new pull request #11436: KAFKA-12648: fill in javadocs for the StreamsException class with new guarantees

2021-10-26 Thread GitBox
ableegoldman opened a new pull request #11436: URL: https://github.com/apache/kafka/pull/11436 Minor followup to [#11405](https://github.com/apache/kafka/pull/11405) / [KIP-783](https://cwiki.apache.org/confluence/display/KAFKA/KIP-783%3A+Add+TaskId+field+to+StreamsException) to write

[GitHub] [kafka] cmccabe commented on pull request #10956: MINOR: fix ZkMetadataCache package name

2021-10-26 Thread GitBox
cmccabe commented on pull request #10956: URL: https://github.com/apache/kafka/pull/10956#issuecomment-952310185 > ping @cmccabe , I'm also thinking about moving MetadataCache into kafka.server.metadata , WDYT? yes, this should be in the `kafka.server.metadata` package, consistent

[GitHub] [kafka] cmccabe merged pull request #11339: MINOR: ClientQuotaRecord is not handled in KRaft MetadataShell

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

[GitHub] [kafka] cmccabe commented on pull request #11339: MINOR: ClientQuotaRecord is not handled in KRaft MetadataShell

2021-10-26 Thread GitBox
cmccabe commented on pull request #11339: URL: https://github.com/apache/kafka/pull/11339#issuecomment-952292489 I re-ran SaslPlainSslEndToEndAuthorizationTest and LeaderElectionCommandTest locally and they both passed. These tests are known to be flaky and the failure is not caused by

[GitHub] [kafka] cmccabe commented on pull request #11339: MINOR: ClientQuotaRecord is not handled in KRaft MetadataShell

2021-10-26 Thread GitBox
cmccabe commented on pull request #11339: URL: https://github.com/apache/kafka/pull/11339#issuecomment-952276357 @dengziming : thanks for this! I'm sorry that I've been so slow to review things lately... too much work piled up. I think it looks good. I especially liked that you added

[jira] [Comment Edited] (KAFKA-13368) Support smart topic polling for consumer with multiple topic subscriptions

2021-10-26 Thread Pedro Cardoso Silva (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434418#comment-17434418 ] Pedro Cardoso Silva edited comment on KAFKA-13368 at 10/26/21, 7:16 PM:

[GitHub] [kafka] upsidedownsmile commented on pull request #11375: KAFKA-10865: Log transformed record in WorkerSinkTask

2021-10-26 Thread GitBox
upsidedownsmile commented on pull request #11375: URL: https://github.com/apache/kafka/pull/11375#issuecomment-952228333 @guozhangwang could you review this please? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [kafka] MasonLegere opened a new pull request #11435: KAFKA-13395: Emit Client Quota Values as Metric

2021-10-26 Thread GitBox
MasonLegere opened a new pull request #11435: URL: https://github.com/apache/kafka/pull/11435 Implementation of proposed changes outlined in KIP 786. - Optionally emits client quota values attached to the `byte-rate` and `throttle-time` under the `kafka.server` MBean. -

[jira] [Commented] (KAFKA-13226) Partition expansion may cause uneven distribution

2021-10-26 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434516#comment-17434516 ] Guozhang Wang commented on KAFKA-13226: --- Hello! It's a bit unfortunate that not everyone here can

[jira] [Created] (KAFKA-13405) Kafka Streams restore-consumer fails to refresh broker IPs after upgrading Kafka cluster

2021-10-26 Thread Daniel O'Halloran (Jira)
Daniel O'Halloran created KAFKA-13405: - Summary: Kafka Streams restore-consumer fails to refresh broker IPs after upgrading Kafka cluster Key: KAFKA-13405 URL:

[jira] [Commented] (KAFKA-13368) Support smart topic polling for consumer with multiple topic subscriptions

2021-10-26 Thread Pedro Cardoso Silva (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434418#comment-17434418 ] Pedro Cardoso Silva commented on KAFKA-13368: - Thank you for your suggestion [~showuon], I

[jira] [Commented] (KAFKA-12334) Add the KIP-631 metadata shell

2021-10-26 Thread Igor Soarez (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434416#comment-17434416 ] Igor Soarez commented on KAFKA-12334: - [~cmccabe] I don't think this is "Resolved". The KIP

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

2021-10-26 Thread Andrei D (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434408#comment-17434408 ] Andrei D commented on KAFKA-12984: -- [~showuon] Thank you for the fast and complete analysis. It'd be

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

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

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

2021-10-26 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434389#comment-17434389 ] Luke Chen commented on KAFKA-12984: --- [~Andy_Dufresne], thanks for the log. I have some clue from there

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

2021-10-26 Thread prabhu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434385#comment-17434385 ] prabhu commented on KAFKA-13400: here is the complete stack trace. this should not happen: offset() is

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

2021-10-26 Thread Gary Russell (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434378#comment-17434378 ] Gary Russell commented on KAFKA-13400: -- While this does not appear to be related to Spring, can you

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

2021-10-26 Thread Andrei D (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434281#comment-17434281 ] Andrei D edited comment on KAFKA-12984 at 10/26/21, 1:23 PM: - [~showuon]

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

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

[GitHub] [kafka] soarez commented on pull request #9577: KAFKA-9837: KIP-589 new RPC for notifying controller log dir failure

2021-10-26 Thread GitBox
soarez commented on pull request #9577: URL: https://github.com/apache/kafka/pull/9577#issuecomment-951893322 @dengziming @mumrah now that 2.8 has been released, should this be rebased and reviewed again? -- This is an automated message from the Apache Git Service. To respond to the

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

2021-10-26 Thread GitBox
dongjinleekr commented on a change in pull request #11430: URL: https://github.com/apache/kafka/pull/11430#discussion_r736487363 ## File path: clients/src/test/java/org/apache/kafka/common/security/JaasContextTest.java ## @@ -172,14 +172,42 @@ public void

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

2021-10-26 Thread GitBox
bvn13 commented on a change in pull request #11430: URL: https://github.com/apache/kafka/pull/11430#discussion_r736438767 ## File path: clients/src/test/java/org/apache/kafka/common/security/JaasContextTest.java ## @@ -172,14 +172,42 @@ public void testMissingSemicolon()

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

2021-10-26 Thread Andrei D (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434281#comment-17434281 ] Andrei D edited comment on KAFKA-12984 at 10/26/21, 11:15 AM: -- Here are

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

2021-10-26 Thread Andrei D (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434281#comment-17434281 ] Andrei D commented on KAFKA-12984: -- Here are debug logs. The freeze happened at 15:48:23

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

2021-10-26 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: logs-insights-results-kafka.csv > Cooperative sticky assignor can get stuck with invalid

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

2021-10-26 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: - Comment: was deleted (was: Here are debug logs. The freeze happened at 15:48:23

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

2021-10-26 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: log-events-viewer-result-kafka.numbers > Cooperative sticky assignor can get stuck with

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

2021-10-26 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: - Comment: was deleted (was: Here are debug logs. The freeze happened at 15:48:23

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

2021-10-26 Thread Andrei D (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434279#comment-17434279 ] Andrei D commented on KAFKA-12984: -- Here are debug logs. The freeze happened at 15:48:23

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

2021-10-26 Thread Andrei D (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434276#comment-17434276 ] Andrei D commented on KAFKA-12984: -- Here are debug logs. The freeze happened at 15:48:23

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

2021-10-26 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: logs-insights-results-kafka.numbers > Cooperative sticky assignor can get stuck with

[jira] [Updated] (KAFKA-13404) Kafka sink connectors do not commit offset correctly if messages are produced in transaction

2021-10-26 Thread Yu-Jhe Li (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu-Jhe Li updated KAFKA-13404: -- Description: The Kafka sink connectors don't commit offset to the latest log-end offset if the

[jira] [Updated] (KAFKA-13404) Kafka sink connectors do not commit offset correctly if messages are produced in transaction

2021-10-26 Thread Yu-Jhe Li (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu-Jhe Li updated KAFKA-13404: -- Attachment: Main.scala > Kafka sink connectors do not commit offset correctly if messages are

[jira] [Updated] (KAFKA-13404) Kafka sink connectors do not commit offset correctly if messages are produced in transaction

2021-10-26 Thread Yu-Jhe Li (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu-Jhe Li updated KAFKA-13404: -- Description: The Kafka sink connectors don't commit offset to the latest log-end offset if the

[jira] [Updated] (KAFKA-13404) Kafka sink connectors do not commit offset correctly if messages are produced in transaction

2021-10-26 Thread Yu-Jhe Li (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu-Jhe Li updated KAFKA-13404: -- Description: The Kafka sink connectors don't commit offset to the latest log-end offset if the

[jira] [Created] (KAFKA-13404) Kafka sink connectors do not commit offset correctly if messages are produced in transaction

2021-10-26 Thread Yu-Jhe Li (Jira)
Yu-Jhe Li created KAFKA-13404: - Summary: Kafka sink connectors do not commit offset correctly if messages are produced in transaction Key: KAFKA-13404 URL: https://issues.apache.org/jira/browse/KAFKA-13404

[GitHub] [kafka] dajac opened a new pull request #11434: MINOR: Fix `GroupCoordinator.onGroupLoaded` log

2021-10-26 Thread GitBox
dajac opened a new pull request #11434: URL: https://github.com/apache/kafka/pull/11434 ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation (including upgrade

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

2021-10-26 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-13403: - Assignee: Luke Chen > KafkaServer crashes when deleting topics due to the race in log deletion

[jira] [Updated] (KAFKA-13394) Topic IDs should be removed from PartitionFetchState if they are no longer sent by the controller

2021-10-26 Thread David Jacot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot updated KAFKA-13394: Priority: Blocker (was: Major) > Topic IDs should be removed from PartitionFetchState if they

[jira] [Updated] (KAFKA-13394) Topic IDs should be removed from PartitionFetchState if they are no longer sent by the controller

2021-10-26 Thread David Jacot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot updated KAFKA-13394: Fix Version/s: 3.1.0 > Topic IDs should be removed from PartitionFetchState if they are no longer

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

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

[jira] [Updated] (KAFKA-13111) Re-evaluate Fetch Sessions when using topic IDs

2021-10-26 Thread David Jacot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot updated KAFKA-13111: Fix Version/s: 3.1.0 > Re-evaluate Fetch Sessions when using topic IDs >

[jira] [Commented] (KAFKA-7632) Support Compression Level

2021-10-26 Thread David Jacot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434195#comment-17434195 ] David Jacot commented on KAFKA-7632: I was reduced the priority. > Support Compression Level >

[jira] [Updated] (KAFKA-7632) Support Compression Level

2021-10-26 Thread David Jacot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot updated KAFKA-7632: --- Priority: Major (was: Blocker) > Support Compression Level > - > >

[jira] [Updated] (KAFKA-13111) Re-evaluate Fetch Sessions when using topic IDs

2021-10-26 Thread David Jacot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot updated KAFKA-13111: Priority: Blocker (was: Major) > Re-evaluate Fetch Sessions when using topic IDs >

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

2021-10-26 Thread Tom Bentley (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434185#comment-17434185 ] Tom Bentley commented on KAFKA-13398: - [~RivenSun] the Admin client is backwards compatible,

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

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

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

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

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

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

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

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

[jira] [Commented] (KAFKA-13368) Support smart topic polling for consumer with multiple topic subscriptions

2021-10-26 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434154#comment-17434154 ] Luke Chen commented on KAFKA-13368: --- [~pcless], thanks for the suggestion. I suggest you can