[GitHub] [kafka] urbandan commented on a change in pull request #11748: KAFKA-12635: Don't emit checkpoints for partitions without any offset…

2022-02-28 Thread GitBox
urbandan commented on a change in pull request #11748: URL: https://github.com/apache/kafka/pull/11748#discussion_r815676139 ## File path: connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointTask.java ## @@ -169,6 +172,7 @@ public String version() {

[GitHub] [kafka] urbandan commented on a change in pull request #11748: KAFKA-12635: Don't emit checkpoints for partitions without any offset…

2022-02-28 Thread GitBox
urbandan commented on a change in pull request #11748: URL: https://github.com/apache/kafka/pull/11748#discussion_r815676139 ## File path: connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointTask.java ## @@ -169,6 +172,7 @@ public String version() {

[GitHub] [kafka] dengziming commented on pull request #11173: KAFKA-13509: Support max timestamp in GetOffsetShell

2022-02-28 Thread GitBox
dengziming commented on pull request #11173: URL: https://github.com/apache/kafka/pull/11173#issuecomment-1054166718 The latest commit rebased on the trunk and add support earliest, latest and max-timestamp for --time. I also test them locally: ``` bin/kafka-run-class.sh kafka.tools.G

[jira] [Comment Edited] (KAFKA-10857) Mirror Maker 2 - replication not working when deploying multiple instances

2022-02-28 Thread Guram Savinov (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17498863#comment-17498863 ] Guram Savinov edited comment on KAFKA-10857 at 2/28/22, 11:50 AM:

[jira] [Commented] (KAFKA-10857) Mirror Maker 2 - replication not working when deploying multiple instances

2022-02-28 Thread Guram Savinov (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17498863#comment-17498863 ] Guram Savinov commented on KAFKA-10857: --- The problem still exists in Kafka 3.x St

[GitHub] [kafka] michalxo commented on pull request #11788: KAFKA-13673: disable idempotence when config conflicts

2022-02-28 Thread GitBox
michalxo commented on pull request #11788: URL: https://github.com/apache/kafka/pull/11788#issuecomment-1054317604 I ran almost full kafka test suite. Got in total around 23 failures, which is great compared to `trunk` where fails almost everything. I have executed it last Wednesday, so

[GitHub] [kafka] cadonna merged pull request #11804: KAFKA-13542: add rebalance reason in Kafka Streams

2022-02-28 Thread GitBox
cadonna merged pull request #11804: URL: https://github.com/apache/kafka/pull/11804 -- 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-13542) Utilize the new Consumer#enforceRebalance(reason) API in Streams

2022-02-28 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-13542. --- Resolution: Fixed > Utilize the new Consumer#enforceRebalance(reason) API in Streams > -

[GitHub] [kafka] dajac commented on a change in pull request #11173: KAFKA-13509: Support max timestamp in GetOffsetShell

2022-02-28 Thread GitBox
dajac commented on a change in pull request #11173: URL: https://github.com/apache/kafka/pull/11173#discussion_r816093355 ## File path: core/src/main/scala/kafka/tools/GetOffsetShell.scala ## @@ -70,12 +71,13 @@ object GetOffsetShell { .withRequiredA

[GitHub] [kafka] mimaison commented on pull request #11572: KAFKA-13510: Connect APIs to list all connector plugins and retrieve …

2022-02-28 Thread GitBox
mimaison commented on pull request #11572: URL: https://github.com/apache/kafka/pull/11572#issuecomment-1054536303 Thanks @C0urante for the review! Again you made some very good suggestions. I've pushed an update. -- This is an automated message from the Apache Git Service. To respond to

[GitHub] [kafka] C0urante commented on a change in pull request #11773: KAFKA-10000: Add new source connector APIs related to exactly-once support (KIP-618)

2022-02-28 Thread GitBox
C0urante commented on a change in pull request #11773: URL: https://github.com/apache/kafka/pull/11773#discussion_r816156264 ## File path: connect/api/src/main/java/org/apache/kafka/connect/source/SourceConnector.java ## @@ -28,4 +30,46 @@ protected SourceConnectorContext

[GitHub] [kafka] C0urante commented on a change in pull request #11572: KAFKA-13510: Connect APIs to list all connector plugins and retrieve …

2022-02-28 Thread GitBox
C0urante commented on a change in pull request #11572: URL: https://github.com/apache/kafka/pull/11572#discussion_r816159562 ## File path: connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/DelegatingClassLoader.java ## @@ -232,8 +252,7 @@ private void in

[GitHub] [kafka] C0urante commented on pull request #11572: KAFKA-13510: Connect APIs to list all connector plugins and retrieve …

2022-02-28 Thread GitBox
C0urante commented on pull request #11572: URL: https://github.com/apache/kafka/pull/11572#issuecomment-1054567120 Noticed that the "resolve comment" option isn't available on this PR, apparently you need to either be the author of a PR or have write access to the repo in order to resolve

[GitHub] [kafka] C0urante edited a comment on pull request #11572: KAFKA-13510: Connect APIs to list all connector plugins and retrieve …

2022-02-28 Thread GitBox
C0urante edited a comment on pull request #11572: URL: https://github.com/apache/kafka/pull/11572#issuecomment-1054567120 Noticed that the "resolve comment" option isn't available on this PR, apparently you need to either be the author of a PR or have write access to the repo in order to r

[jira] [Commented] (KAFKA-12901) Metadata not updated after broker restart.

2022-02-28 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499138#comment-17499138 ] Jun Rao commented on KAFKA-12901: - [~suriyav] : Did you see the same log error as in KAF

[jira] [Commented] (KAFKA-13418) Brokers disconnect intermittently with TLS1.3

2022-02-28 Thread Yiming Zang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499167#comment-17499167 ] Yiming Zang commented on KAFKA-13418: - Thanks [~skokoori] for creating this issue, a

[jira] [Commented] (KAFKA-9957) Kafka Controller doesn't failover during hardware failure

2022-02-28 Thread John D (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499166#comment-17499166 ] John D commented on KAFKA-9957: --- I am facing an exact similar issue, # a broker is having

[GitHub] [kafka] wcarlson5 commented on a change in pull request #11813: KAFKA-12648: fix #add/removeNamedTopology blocking behavior when app is in CREATED

2022-02-28 Thread GitBox
wcarlson5 commented on a change in pull request #11813: URL: https://github.com/apache/kafka/pull/11813#discussion_r816239929 ## File path: streams/src/test/java/org/apache/kafka/streams/processor/internals/NamedTopologyTest.java ## @@ -149,7 +149,7 @@ public void shouldThrow

[jira] [Assigned] (KAFKA-13672) Flaky test kafka.server.DynamicBrokerReconfigurationTest.testThreadPoolResize()

2022-02-28 Thread Liam Clarke-Hutchinson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liam Clarke-Hutchinson reassigned KAFKA-13672: -- Assignee: Liam Clarke-Hutchinson > Flaky test > kafka.server.Dynamic

[jira] [Commented] (KAFKA-13658) Upgrade vulnerable dependencies jan 2022

2022-02-28 Thread Pratim Chaudhuri (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499202#comment-17499202 ] Pratim Chaudhuri commented on KAFKA-13658: -- This also affects version 3.0 and 3

[GitHub] [kafka] ableegoldman commented on a change in pull request #11813: KAFKA-12648: fix #add/removeNamedTopology blocking behavior when app is in CREATED

2022-02-28 Thread GitBox
ableegoldman commented on a change in pull request #11813: URL: https://github.com/apache/kafka/pull/11813#discussion_r816305679 ## File path: streams/src/test/java/org/apache/kafka/streams/processor/internals/NamedTopologyTest.java ## @@ -124,6 +124,17 @@ public void shouldA

[GitHub] [kafka] ableegoldman commented on a change in pull request #11813: KAFKA-12648: fix #add/removeNamedTopology blocking behavior when app is in CREATED

2022-02-28 Thread GitBox
ableegoldman commented on a change in pull request #11813: URL: https://github.com/apache/kafka/pull/11813#discussion_r816306370 ## File path: streams/src/test/java/org/apache/kafka/streams/processor/internals/NamedTopologyTest.java ## @@ -149,7 +149,7 @@ public void shouldTh

[GitHub] [kafka] ableegoldman commented on a change in pull request #11813: KAFKA-12648: fix #add/removeNamedTopology blocking behavior when app is in CREATED

2022-02-28 Thread GitBox
ableegoldman commented on a change in pull request #11813: URL: https://github.com/apache/kafka/pull/11813#discussion_r816306491 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/KafkaStreamsNamedTopologyWrapper.java ## @@ -230,53 +

[GitHub] [kafka] ableegoldman commented on a change in pull request #11813: KAFKA-12648: fix #add/removeNamedTopology blocking behavior when app is in CREATED

2022-02-28 Thread GitBox
ableegoldman commented on a change in pull request #11813: URL: https://github.com/apache/kafka/pull/11813#discussion_r816307586 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/KafkaStreamsNamedTopologyWrapper.java ## @@ -230,53 +

[GitHub] [kafka] ableegoldman commented on a change in pull request #11813: KAFKA-12648: fix #add/removeNamedTopology blocking behavior when app is in CREATED

2022-02-28 Thread GitBox
ableegoldman commented on a change in pull request #11813: URL: https://github.com/apache/kafka/pull/11813#discussion_r816307925 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/KafkaStreamsNamedTopologyWrapper.java ## @@ -230,53 +

[jira] [Updated] (KAFKA-13699) ProcessorContext does not expose Stream Time

2022-02-28 Thread Shay Lin (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shay Lin updated KAFKA-13699: - Description: As a KS developer, I would like to leverage [KIP-622|https://cwiki.apache.org/confluence/d

[jira] [Created] (KAFKA-13699) ProcessorContext does not expose Stream Time

2022-02-28 Thread Shay Lin (Jira)
Shay Lin created KAFKA-13699: Summary: ProcessorContext does not expose Stream Time Key: KAFKA-13699 URL: https://issues.apache.org/jira/browse/KAFKA-13699 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-13699) ProcessorContext does not expose Stream Time

2022-02-28 Thread Shay Lin (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shay Lin updated KAFKA-13699: - Description: As a KS developer, I would like to leverage [KIP-622|https://cwiki.apache.org/confluence/d

[GitHub] [kafka] ableegoldman commented on a change in pull request #11813: KAFKA-12648: fix #add/removeNamedTopology blocking behavior when app is in CREATED

2022-02-28 Thread GitBox
ableegoldman commented on a change in pull request #11813: URL: https://github.com/apache/kafka/pull/11813#discussion_r816337445 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/KafkaStreamsNamedTopologyWrapper.java ## @@ -230,53 +

[GitHub] [kafka] ableegoldman commented on a change in pull request #11813: KAFKA-12648: fix #add/removeNamedTopology blocking behavior when app is in CREATED

2022-02-28 Thread GitBox
ableegoldman commented on a change in pull request #11813: URL: https://github.com/apache/kafka/pull/11813#discussion_r816337811 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/KafkaStreamsNamedTopologyWrapper.java ## @@ -100,7 +1

[jira] [Created] (KAFKA-13700) Kafka reporting corrupted block message.

2022-02-28 Thread Uday Bhaskar (Jira)
Uday Bhaskar created KAFKA-13700: Summary: Kafka reporting corrupted block message. Key: KAFKA-13700 URL: https://issues.apache.org/jira/browse/KAFKA-13700 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-13700) Kafka reporting CorruptRecordException exception

2022-02-28 Thread Uday Bhaskar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Uday Bhaskar updated KAFKA-13700: - Summary: Kafka reporting CorruptRecordException exception (was: Kafka reporting corrupted block

[GitHub] [kafka] ableegoldman commented on a change in pull request #11812: KAFKA-12738: address minor followup and consolidate integration tests of PR #11787

2022-02-28 Thread GitBox
ableegoldman commented on a change in pull request #11812: URL: https://github.com/apache/kafka/pull/11812#discussion_r816342899 ## File path: streams/src/test/java/org/apache/kafka/streams/integration/NamedTopologyIntegrationTest.java ## @@ -775,6 +781,70 @@ public void shoul

[GitHub] [kafka] lihaosky opened a new pull request #11820: [RFC][2/N] add restoration logic for RocksDBTimeOrderedWindowStore

2022-02-28 Thread GitBox
lihaosky opened a new pull request #11820: URL: https://github.com/apache/kafka/pull/11820 Add restoration logic for `RocksDBTimeOrderedWindowStore`. Changelog's key is serialized from `WindowKeySchema` and transform key format to match index and base store's format ### Comm

[jira] [Commented] (KAFKA-13514) Flakey test StickyAssignorTest

2022-02-28 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499259#comment-17499259 ] A. Sophie Blee-Goldman commented on KAFKA-13514: Hmm, I'm sure it was fr

[jira] [Comment Edited] (KAFKA-13514) Flakey test StickyAssignorTest

2022-02-28 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499259#comment-17499259 ] A. Sophie Blee-Goldman edited comment on KAFKA-13514 at 3/1/22, 1:28 AM: -

[jira] [Assigned] (KAFKA-13658) Upgrade vulnerable dependencies jan 2022

2022-02-28 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-13658: - Assignee: (was: Luke Chen) > Upgrade vulnerable dependencies jan 2022 > ---

[jira] [Commented] (KAFKA-13658) Upgrade vulnerable dependencies jan 2022

2022-02-28 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499271#comment-17499271 ] Luke Chen commented on KAFKA-13658: --- [~pratimsc] , go ahead to submit PR to fix this i

[GitHub] [kafka] wcarlson5 commented on a change in pull request #11813: KAFKA-12648: fix #add/removeNamedTopology blocking behavior when app is in CREATED

2022-02-28 Thread GitBox
wcarlson5 commented on a change in pull request #11813: URL: https://github.com/apache/kafka/pull/11813#discussion_r816411304 ## File path: streams/src/test/java/org/apache/kafka/streams/processor/internals/NamedTopologyTest.java ## @@ -149,7 +149,7 @@ public void shouldThrow

[GitHub] [kafka] LiamClarkeNZ opened a new pull request #11821: KAFKA-13672 Flaky test kafka.server.DynamicBrokerReconfigurationTest.testThreadPoolResize() [WIP]

2022-02-28 Thread GitBox
LiamClarkeNZ opened a new pull request #11821: URL: https://github.com/apache/kafka/pull/11821 WIP PR to get better insight into flakiness in CI context. -- 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 t

[GitHub] [kafka] showuon opened a new pull request #11822: [WIP] MINOR: add test

2022-02-28 Thread GitBox
showuon opened a new pull request #11822: URL: https://github.com/apache/kafka/pull/11822 *More detailed description of your change, if necessary. The PR title and PR message become the squashed commit message, so use a separate comment to ping reviewers.* *Summary of testing

[jira] [Updated] (KAFKA-9374) Worker can be disabled by blocked connectors

2022-02-28 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-9374: - Description: If a connector hangs during any of its {{{}initialize{}}}, {{{}start{}}}, {{{}stop{

[GitHub] [kafka] dengziming commented on a change in pull request #11173: KAFKA-13509: Support max timestamp in GetOffsetShell

2022-02-28 Thread GitBox
dengziming commented on a change in pull request #11173: URL: https://github.com/apache/kafka/pull/11173#discussion_r816447498 ## File path: core/src/test/scala/kafka/tools/GetOffsetShellParsingTest.scala ## @@ -17,191 +17,231 @@ package kafka.tools -import org.apache.kafk

[GitHub] [kafka] hgeraldino commented on a change in pull request #11773: KAFKA-10000: Add new source connector APIs related to exactly-once support (KIP-618)

2022-02-28 Thread GitBox
hgeraldino commented on a change in pull request #11773: URL: https://github.com/apache/kafka/pull/11773#discussion_r816451067 ## File path: connect/api/src/main/java/org/apache/kafka/connect/source/SourceConnector.java ## @@ -28,4 +30,46 @@ protected SourceConnectorConte

[jira] [Commented] (KAFKA-13631) Warning "Ignoring await stop request for non-present connector..." when shutting down connector via API in distributed mode

2022-02-28 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499337#comment-17499337 ] Chris Egerton commented on KAFKA-13631: --- Interestingly enough, it seemed initially

[jira] [Comment Edited] (KAFKA-13631) Warning "Ignoring await stop request for non-present connector..." when shutting down connector via API in distributed mode

2022-02-28 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499337#comment-17499337 ] Chris Egerton edited comment on KAFKA-13631 at 3/1/22, 5:26 AM: --

[jira] [Comment Edited] (KAFKA-13631) Warning "Ignoring await stop request for non-present connector..." when shutting down connector via API in distributed mode

2022-02-28 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499337#comment-17499337 ] Chris Egerton edited comment on KAFKA-13631 at 3/1/22, 5:27 AM: --

[GitHub] [kafka] ableegoldman opened a new pull request #11823: MINOR: set log4j.logger.kafka and all Config logger levels to ERROR for Streams tests

2022-02-28 Thread GitBox
ableegoldman opened a new pull request #11823: URL: https://github.com/apache/kafka/pull/11823 Pretty much any time we have an integration test failure that's flaky or only exposed when running on Jenkins through the PR builds, it's impossible to debug if it cannot be reproduced locally as

[GitHub] [kafka] ableegoldman opened a new pull request #11824: KAFKA-12648: standardize startup timeout to fix some flaky NamedTopologyIntegrationTest tests

2022-02-28 Thread GitBox
ableegoldman opened a new pull request #11824: URL: https://github.com/apache/kafka/pull/11824 Seen a few of the new tests added [fail on PR builds](https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-11812/3/testReport/org.apache.kafka.streams.integration/NamedTopologyIntegrationTes

[GitHub] [kafka] showuon commented on pull request #11788: KAFKA-13673: disable idempotence when config conflicts

2022-02-28 Thread GitBox
showuon commented on pull request #11788: URL: https://github.com/apache/kafka/pull/11788#issuecomment-1055087971 Thanks for verifying it @michalxo ! -- 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

[jira] [Created] (KAFKA-13701) Pin background worker threads for certain background work (ex: UnifiedLog.flush())

2022-02-28 Thread Kowshik Prakasam (Jira)
Kowshik Prakasam created KAFKA-13701: Summary: Pin background worker threads for certain background work (ex: UnifiedLog.flush()) Key: KAFKA-13701 URL: https://issues.apache.org/jira/browse/KAFKA-13701

[GitHub] [kafka] kowshik commented on pull request #11814: MINOR: Ensure LocalLog.flush() is immune to recoveryPoint change by different thread

2022-02-28 Thread GitBox
kowshik commented on pull request #11814: URL: https://github.com/apache/kafka/pull/11814#issuecomment-1055098574 @junrao Thanks for the review! I checked the test failures, and they look unrelated to this PR. I agree, your suggestion is a good way to simplify the code and it will be a lot

[jira] [Updated] (KAFKA-13701) Pin background worker threads for certain background work (ex: UnifiedLog.flush())

2022-02-28 Thread Kowshik Prakasam (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kowshik Prakasam updated KAFKA-13701: - Description: Certain background work such as UnifiedLog.flush() need not support concur

[GitHub] [kafka] yangyijun1990 opened a new pull request #11825: 3.1

2022-02-28 Thread GitBox
yangyijun1990 opened a new pull request #11825: URL: https://github.com/apache/kafka/pull/11825 *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 t

[GitHub] [kafka] yangyijun1990 opened a new pull request #11826: 2.8

2022-02-28 Thread GitBox
yangyijun1990 opened a new pull request #11826: URL: https://github.com/apache/kafka/pull/11826 *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 t

[GitHub] [kafka] yangyijun1990 commented on pull request #11826: 2.8

2022-02-28 Thread GitBox
yangyijun1990 commented on pull request #11826: URL: https://github.com/apache/kafka/pull/11826#issuecomment-1055122657 update -- 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 commen