[GitHub] [kafka] edipesh19 opened a new pull request #11223: Upgrade zookeeper version to 3.6.3

2021-08-17 Thread GitBox
edipesh19 opened a new pull request #11223: URL: https://github.com/apache/kafka/pull/11223 *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 testi

[GitHub] [kafka] edipesh19 closed pull request #11223: Upgrade zookeeper version to 3.6.3

2021-08-17 Thread GitBox
edipesh19 closed pull request #11223: URL: https://github.com/apache/kafka/pull/11223 -- 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

[jira] [Assigned] (KAFKA-13032) Impossible stacktrace

2021-08-17 Thread Yanwen Lin (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanwen Lin reassigned KAFKA-13032: -- Assignee: Yanwen Lin > Impossible stacktrace > - > > Key:

[GitHub] [kafka] venkatesh010 commented on pull request #6233: KAFKA-7902: Replace original loginContext if SASL/OAUTHBEARER refresh login fails

2021-08-17 Thread GitBox
venkatesh010 commented on pull request #6233: URL: https://github.com/apache/kafka/pull/6233#issuecomment-900069794 @rondagostino @rajinisivaram which version of apache Kafka client or if I'm using spring cloud stream, which version of spring-kafka should I use..to incorporate this fix?

[GitHub] [kafka] venkatesh010 commented on pull request #6233: KAFKA-7902: Replace original loginContext if SASL/OAUTHBEARER refresh login fails

2021-08-17 Thread GitBox
venkatesh010 commented on pull request #6233: URL: https://github.com/apache/kafka/pull/6233#issuecomment-900070176 And is restarting service a temporary solution for it? As loginContext will get created again post restart of client -- This is an automated message from the Apache Git Ser

[GitHub] [kafka] rajinisivaram commented on a change in pull request #11221: KAFKA-13207: Don't partition state on fetch response with diverging epoch if partition removed from fetcher

2021-08-17 Thread GitBox
rajinisivaram commented on a change in pull request #11221: URL: https://github.com/apache/kafka/pull/11221#discussion_r690150564 ## File path: core/src/main/scala/kafka/server/AbstractFetcherThread.scala ## @@ -268,7 +262,10 @@ abstract class AbstractFetcherThread(name: String

[jira] [Updated] (KAFKA-13196) MirrorMaker 2 not always start tasks

2021-08-17 Thread Jozef Vilcek (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jozef Vilcek updated KAFKA-13196: - Description: I am using MirrorMaker 2.0 and running it via [  MirrorMaker.java|https://github.co

[jira] [Assigned] (KAFKA-12421) Improve controller's atomic grouping

2021-08-17 Thread HaiyuanZhao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] HaiyuanZhao reassigned KAFKA-12421: --- Assignee: HaiyuanZhao > Improve controller's atomic grouping >

[GitHub] [kafka] dajac commented on a change in pull request #11221: KAFKA-13207: Skip truncation on fetch response with diverging epoch if partition removed from fetcher

2021-08-17 Thread GitBox
dajac commented on a change in pull request #11221: URL: https://github.com/apache/kafka/pull/11221#discussion_r690383569 ## File path: core/src/main/scala/kafka/server/AbstractFetcherThread.scala ## @@ -262,22 +263,29 @@ abstract class AbstractFetcherThread(name: String,

[GitHub] [kafka] jsancio commented on a change in pull request #11216: KAFKA-13198: Stop replicas when reassigned

2021-08-17 Thread GitBox
jsancio commented on a change in pull request #11216: URL: https://github.com/apache/kafka/pull/11216#discussion_r690442367 ## File path: core/src/main/scala/kafka/server/ReplicaManager.scala ## @@ -2074,48 +2073,23 @@ class ReplicaManager(val config: KafkaConfig, } }

[GitHub] [kafka] jsancio commented on a change in pull request #11216: KAFKA-13198: Stop replicas when reassigned

2021-08-17 Thread GitBox
jsancio commented on a change in pull request #11216: URL: https://github.com/apache/kafka/pull/11216#discussion_r690455391 ## File path: core/src/test/scala/integration/kafka/server/KRaftClusterTest.scala ## @@ -410,6 +421,32 @@ class KRaftClusterTest { } } + privat

[GitHub] [kafka] junrao commented on a change in pull request #11216: KAFKA-13198: Stop replicas when reassigned

2021-08-17 Thread GitBox
junrao commented on a change in pull request #11216: URL: https://github.com/apache/kafka/pull/11216#discussion_r690492221 ## File path: core/src/main/scala/kafka/server/BrokerServer.scala ## @@ -113,7 +113,7 @@ class BrokerServer( var dynamicConfigHandlers: Map[String, Co

[jira] [Created] (KAFKA-13209) Upgrade jetty-server to 9.4.43.v20210629

2021-08-17 Thread Justine Olshan (Jira)
Justine Olshan created KAFKA-13209: -- Summary: Upgrade jetty-server to 9.4.43.v20210629 Key: KAFKA-13209 URL: https://issues.apache.org/jira/browse/KAFKA-13209 Project: Kafka Issue Type: Impr

[jira] [Updated] (KAFKA-13209) Upgrade jetty-server to fix CVE-2021-34429

2021-08-17 Thread Justine Olshan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Justine Olshan updated KAFKA-13209: --- Summary: Upgrade jetty-server to fix CVE-2021-34429 (was: Upgrade jetty-server to 9.4.43.v2

[GitHub] [kafka] rajinisivaram commented on pull request #11221: KAFKA-13207: Skip truncation on fetch response with diverging epoch if partition removed from fetcher

2021-08-17 Thread GitBox
rajinisivaram commented on pull request #11221: URL: https://github.com/apache/kafka/pull/11221#issuecomment-900433010 @dajac @hachikuji Thanks for the reviews, merging. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [kafka] rajinisivaram merged pull request #11221: KAFKA-13207: Skip truncation on fetch response with diverging epoch if partition removed from fetcher

2021-08-17 Thread GitBox
rajinisivaram merged pull request #11221: URL: https://github.com/apache/kafka/pull/11221 -- 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] jolshan opened a new pull request #11224: KAFKA-13209: Upgrade jetty-server to fix CVE-2021-34429

2021-08-17 Thread GitBox
jolshan opened a new pull request #11224: URL: https://github.com/apache/kafka/pull/11224 Upgrading to 9.4.43.v20210629 Release notes: https://github.com/eclipse/jetty.project/releases/tag/jetty-9.4.43.v20210629 ### Committer Checklist (excluded from commit message) - [ ] Verif

[GitHub] [kafka] rondagostino commented on pull request #6233: KAFKA-7902: Replace original loginContext if SASL/OAUTHBEARER refresh login fails

2021-08-17 Thread GitBox
rondagostino commented on pull request #6233: URL: https://github.com/apache/kafka/pull/6233#issuecomment-900456795 @venkatesh010 https://issues.apache.org/jira/browse/KAFKA-7902 says `Fix Version/s: 2.2.0, 2.1.1` -- This is an automated message from the Apache Git Service. To respon

[GitHub] [kafka] rondagostino commented on pull request #6233: KAFKA-7902: Replace original loginContext if SASL/OAUTHBEARER refresh login fails

2021-08-17 Thread GitBox
rondagostino commented on pull request #6233: URL: https://github.com/apache/kafka/pull/6233#issuecomment-900457425 .. and yes, restarting the client will get the client out of the bad state if you happen to be using a version of the code with this bug. -- This is an automated message fr

[GitHub] [kafka] venkatesh010 commented on pull request #6233: KAFKA-7902: Replace original loginContext if SASL/OAUTHBEARER refresh login fails

2021-08-17 Thread GitBox
venkatesh010 commented on pull request #6233: URL: https://github.com/apache/kafka/pull/6233#issuecomment-900514731 -- 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 unsub

[GitHub] [kafka] omkreddy merged pull request #11224: KAFKA-13209: Upgrade jetty-server to fix CVE-2021-34429

2021-08-17 Thread GitBox
omkreddy merged pull request #11224: URL: https://github.com/apache/kafka/pull/11224 -- 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] jsancio commented on a change in pull request #11216: KAFKA-13198: Stop replicas when reassigned

2021-08-17 Thread GitBox
jsancio commented on a change in pull request #11216: URL: https://github.com/apache/kafka/pull/11216#discussion_r690620725 ## File path: core/src/main/scala/kafka/server/BrokerServer.scala ## @@ -113,7 +113,7 @@ class BrokerServer( var dynamicConfigHandlers: Map[String, C

[GitHub] [kafka] dajac commented on pull request #11221: KAFKA-13207: Skip truncation on fetch response with diverging epoch if partition removed from fetcher

2021-08-17 Thread GitBox
dajac commented on pull request #11221: URL: https://github.com/apache/kafka/pull/11221#issuecomment-900541736 @rajinisivaram Should we also add it to 2.8 branch? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

[jira] [Assigned] (KAFKA-13209) Upgrade jetty-server to fix CVE-2021-34429

2021-08-17 Thread Justine Olshan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Justine Olshan reassigned KAFKA-13209: -- Assignee: Justine Olshan > Upgrade jetty-server to fix CVE-2021-34429 > -

[jira] [Updated] (KAFKA-13209) Upgrade jetty-server to fix CVE-2021-34429

2021-08-17 Thread Justine Olshan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Justine Olshan updated KAFKA-13209: --- Fix Version/s: 2.7.1 2.8.1 3.0.0 > Upgrade jetty-serve

[jira] [Updated] (KAFKA-13209) Upgrade jetty-server to fix CVE-2021-34429

2021-08-17 Thread Justine Olshan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Justine Olshan updated KAFKA-13209: --- Fix Version/s: (was: 2.7.1) 2.7.2 > Upgrade jetty-server to fix CVE-2

[jira] [Resolved] (KAFKA-13209) Upgrade jetty-server to fix CVE-2021-34429

2021-08-17 Thread Justine Olshan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Justine Olshan resolved KAFKA-13209. Resolution: Fixed > Upgrade jetty-server to fix CVE-2021-34429 > -

[GitHub] [kafka] rajinisivaram commented on pull request #11221: KAFKA-13207: Skip truncation on fetch response with diverging epoch if partition removed from fetcher

2021-08-17 Thread GitBox
rajinisivaram commented on pull request #11221: URL: https://github.com/apache/kafka/pull/11221#issuecomment-900554192 @dajac Yes, merged to 3.0 and 2.8 as well, thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Resolved] (KAFKA-13207) Replica fetcher should not update partition state on diverging epoch if partition removed from fetcher

2021-08-17 Thread Rajini Sivaram (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-13207. Resolution: Fixed > Replica fetcher should not update partition state on diverging epoch i

[GitHub] [kafka] vvcephei commented on a change in pull request #11213: KAFKA-13201: Convert KTable aggregations to new PAPI

2021-08-17 Thread GitBox
vvcephei commented on a change in pull request #11213: URL: https://github.com/apache/kafka/pull/11213#discussion_r690642563 ## File path: streams/src/test/java/org/apache/kafka/test/MockInternalNewProcessorContext.java ## @@ -0,0 +1,172 @@ +/* + * Licensed to the Apache Softw

[GitHub] [kafka] rondagostino commented on pull request #6233: KAFKA-7902: Replace original loginContext if SASL/OAUTHBEARER refresh login fails

2021-08-17 Thread GitBox
rondagostino commented on pull request #6233: URL: https://github.com/apache/kafka/pull/6233#issuecomment-900565005 You can get the specified versions at https://kafka.apache.org/downloads. This fix appears in the release notes. -- This is an automated message from the Apache Git Servic

[GitHub] [kafka] junrao merged pull request #11216: KAFKA-13198: Stop replicas when reassigned

2021-08-17 Thread GitBox
junrao merged pull request #11216: URL: https://github.com/apache/kafka/pull/11216 -- 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] [Resolved] (KAFKA-13198) TopicsDelta doesn't update deleted topic when processing PartitionChangeRecord

2021-08-17 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-13198. - Resolution: Fixed merged the PR to 3.0 and trunk. > TopicsDelta doesn't update deleted topic when proce

[jira] [Commented] (KAFKA-13152) Replace "buffered.records.per.partition" with "input.buffer.max.bytes"

2021-08-17 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17400641#comment-17400641 ] Guozhang Wang commented on KAFKA-13152: --- [~sagarrao] [~mjsax] (also cc [~desai.p.r

[jira] [Commented] (KAFKA-13203) GlobalTopic is added to main consumer subscription

2021-08-17 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17400645#comment-17400645 ] Guozhang Wang commented on KAFKA-13203: --- Which version of Kafka is this issue repo

[jira] [Commented] (KAFKA-13152) Replace "buffered.records.per.partition" with "input.buffer.max.bytes"

2021-08-17 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17400647#comment-17400647 ] Matthias J. Sax commented on KAFKA-13152: - For (1), I think we need to take time

[jira] [Commented] (KAFKA-13152) Replace "buffered.records.per.partition" with "input.buffer.max.bytes"

2021-08-17 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17400651#comment-17400651 ] Guozhang Wang commented on KAFKA-13152: --- Yeah that's a good point. I think we shou

[jira] [Commented] (KAFKA-13197) KStream-GlobalKTable join semantics don't match documentation

2021-08-17 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17400653#comment-17400653 ] Guozhang Wang commented on KAFKA-13197: --- Thanks for filing this [~twbecker]. The c

[jira] [Commented] (KAFKA-8295) Add merge() operator to State Stores.

2021-08-17 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17400672#comment-17400672 ] Guozhang Wang commented on KAFKA-8295: -- Just to add some context here: we are having

[GitHub] [kafka] guozhangwang commented on a change in pull request #11184: KAFKA-13172: Add downgrade guidance note for 3.0

2021-08-17 Thread GitBox
guozhangwang commented on a change in pull request #11184: URL: https://github.com/apache/kafka/pull/11184#discussion_r690792216 ## File path: docs/streams/upgrade-guide.html ## @@ -52,6 +52,15 @@ Upgrade Guide and API Changes restart all new ({{fullDotVersion}}) appl

[GitHub] [kafka] guozhangwang commented on a change in pull request #11184: KAFKA-13172: Add downgrade guidance note for 3.0

2021-08-17 Thread GitBox
guozhangwang commented on a change in pull request #11184: URL: https://github.com/apache/kafka/pull/11184#discussion_r690792840 ## File path: docs/streams/upgrade-guide.html ## @@ -52,6 +52,15 @@ Upgrade Guide and API Changes restart all new ({{fullDotVersion}}) appl

[GitHub] [kafka] guozhangwang merged pull request #11184: KAFKA-13172: Add downgrade guidance note for 3.0

2021-08-17 Thread GitBox
guozhangwang merged pull request #11184: URL: https://github.com/apache/kafka/pull/11184 -- 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] guozhangwang commented on pull request #11184: KAFKA-13172: Add downgrade guidance note for 3.0

2021-08-17 Thread GitBox
guozhangwang commented on pull request #11184: URL: https://github.com/apache/kafka/pull/11184#issuecomment-900710127 Cherry-picked to 3.0 to be included in the 3.0 docs cc @kkonstantine -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[jira] [Created] (KAFKA-13210) fetch/findSessions queries with open endpoints for SessionStore/WindowStore

2021-08-17 Thread Luke Chen (Jira)
Luke Chen created KAFKA-13210: - Summary: fetch/findSessions queries with open endpoints for SessionStore/WindowStore Key: KAFKA-13210 URL: https://issues.apache.org/jira/browse/KAFKA-13210 Project: Kafka

[GitHub] [kafka] Justinwins commented on a change in pull request #10652: KAFKA-9726 IdentityReplicationPolicy

2021-08-17 Thread GitBox
Justinwins commented on a change in pull request #10652: URL: https://github.com/apache/kafka/pull/10652#discussion_r684042834 ## File path: docs/upgrade.html ## @@ -83,7 +83,13 @@ Notable changes in 3 understood by brokers or version 2.5 or higher, so you must upgrade