[GitHub] [kafka] vvcephei commented on a change in pull request #11557: KAFKA-13491: IQv2 framework

vvcephei commented on a change in pull request #11557: URL: https://github.com/apache/kafka/pull/11557#discussion_r762370915 ## File path: streams/src/main/java/org/apache/kafka/streams/state/internals/StoreQueryUtils.java ## @@ -0,0 +1,65 @@ +/* + * Licensed to the Apache Sof

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

hachikuji commented on a change in pull request #11345: URL: https://github.com/apache/kafka/pull/11345#discussion_r762370413 ## File path: core/src/main/scala/kafka/log/UnifiedLog.scala ## @@ -1498,28 +1498,44 @@ class UnifiedLog(@volatile var logStartOffset: Long, produc

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

hachikuji commented on a change in pull request #11345: URL: https://github.com/apache/kafka/pull/11345#discussion_r762370413 ## File path: core/src/main/scala/kafka/log/UnifiedLog.scala ## @@ -1498,28 +1498,44 @@ class UnifiedLog(@volatile var logStartOffset: Long, produc

[GitHub] [kafka] florin-akermann commented on a change in pull request #11456: KAFKA-13351: Add possibility to write kafka headers in Kafka Console Producer

florin-akermann commented on a change in pull request #11456: URL: https://github.com/apache/kafka/pull/11456#discussion_r762368709 ## File path: core/src/main/scala/kafka/tools/ConsoleProducer.scala ## @@ -274,28 +296,74 @@ object ConsoleProducer { parseKey = props.ge

[GitHub] [kafka] florin-akermann commented on a change in pull request #11456: KAFKA-13351: Add possibility to write kafka headers in Kafka Console Producer

florin-akermann commented on a change in pull request #11456: URL: https://github.com/apache/kafka/pull/11456#discussion_r762369085 ## File path: core/src/main/scala/kafka/tools/ConsoleProducer.scala ## @@ -274,28 +296,74 @@ object ConsoleProducer { parseKey = props.ge

[GitHub] [kafka] junrao commented on a change in pull request #11390: [KAFKA-13369] Follower fetch protocol changes for tiered storage.

junrao commented on a change in pull request #11390: URL: https://github.com/apache/kafka/pull/11390#discussion_r760491245 ## File path: core/src/main/scala/kafka/log/UnifiedLog.scala ## @@ -288,13 +292,21 @@ class UnifiedLog(@volatile var logStartOffset: Long, @volatile v

[GitHub] [kafka] florin-akermann commented on a change in pull request #11456: KAFKA-13351: Add possibility to write kafka headers in Kafka Console Producer

florin-akermann commented on a change in pull request #11456: URL: https://github.com/apache/kafka/pull/11456#discussion_r762368754 ## File path: core/src/main/scala/kafka/tools/ConsoleProducer.scala ## @@ -208,9 +213,22 @@ object ConsoleProducer { .defaultsTo(1024*100)

[GitHub] [kafka] florin-akermann commented on a change in pull request #11456: KAFKA-13351: Add possibility to write kafka headers in Kafka Console Producer

florin-akermann commented on a change in pull request #11456: URL: https://github.com/apache/kafka/pull/11456#discussion_r762368709 ## File path: core/src/main/scala/kafka/tools/ConsoleProducer.scala ## @@ -274,28 +296,74 @@ object ConsoleProducer { parseKey = props.ge

[jira] [Created] (KAFKA-13507) GlobalProcessor ignored user specified names

Matthias J. Sax created KAFKA-13507: --- Summary: GlobalProcessor ignored user specified names Key: KAFKA-13507 URL: https://issues.apache.org/jira/browse/KAFKA-13507 Project: Kafka Issue Type

[GitHub] [kafka] jeffkbkim opened a new pull request #11566: KAFKA-13495: add reason to JoinGroupRequest

jeffkbkim opened a new pull request #11566: URL: https://github.com/apache/kafka/pull/11566 As part of [KIP-800](https://cwiki.apache.org/confluence/display/KAFKA/KIP-800%3A+Add+reason+to+JoinGroupRequest+and+LeaveGroupRequest), this patch aims to add a reason to why a consumer is joining

[jira] [Updated] (KAFKA-13507) GlobalProcessor ignores user specified names

[ https://issues.apache.org/jira/browse/KAFKA-13507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13507: Summary: GlobalProcessor ignores user specified names (was: GlobalProcessor ignored user

[jira] [Assigned] (KAFKA-13506) IQv2: Transmit position to standbys

[ https://issues.apache.org/jira/browse/KAFKA-13506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-13506: Assignee: Vicky Papavasileiou > IQv2: Transmit position to standbys > ---

[jira] [Created] (KAFKA-13506) IQv2: Transmit position to standbys

John Roesler created KAFKA-13506: Summary: IQv2: Transmit position to standbys Key: KAFKA-13506 URL: https://issues.apache.org/jira/browse/KAFKA-13506 Project: Kafka Issue Type: Sub-task

[GitHub] [kafka] mjsax merged pull request #11479: KAFKA-12648: Make changing the named topologies have a blocking option

mjsax merged pull request #11479: URL: https://github.com/apache/kafka/pull/11479 -- 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] hachikuji commented on a change in pull request #11503: KAFKA-13456: Tighten KRaft config checks/constraints

hachikuji commented on a change in pull request #11503: URL: https://github.com/apache/kafka/pull/11503#discussion_r762175150 ## File path: core/src/main/scala/kafka/server/KafkaConfig.scala ## @@ -748,7 +749,8 @@ object KafkaConfig { "Different security (SSL and SASL) set

[GitHub] [kafka] C0urante commented on a change in pull request #11046: KAFKA-12980: Return empty record batch from Consumer::poll when position advances due to aborted transactions

C0urante commented on a change in pull request #11046: URL: https://github.com/apache/kafka/pull/11046#discussion_r762182442 ## File path: clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java ## @@ -728,6 +728,15 @@ public void onFailure(RuntimeExcept

[jira] [Commented] (KAFKA-13505) Kafka Connect should respect Avro 1.10.X enum defaults spec

[ https://issues.apache.org/jira/browse/KAFKA-13505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17453177#comment-17453177 ] Jeremy Custenborder commented on KAFKA-13505: - I was aiming for you to help

[GitHub] [kafka] vvcephei merged pull request #11557: KAFKA-13491: IQv2 framework

vvcephei merged pull request #11557: URL: https://github.com/apache/kafka/pull/11557 -- 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] vvcephei commented on pull request #11557: KAFKA-13491: IQv2 framework

vvcephei commented on pull request #11557: URL: https://github.com/apache/kafka/pull/11557#issuecomment-985750865 The failures are unrelated: ``` Build / ARM / kafka.server.ReplicaManagerTest.[1] usesTopicIds=true Build / JDK 8 and Scala 2.12 / kafka.server.ReplicaManagerTes

[GitHub] [kafka] vvcephei commented on a change in pull request #11557: KAFKA-13491: IQv2 framework

vvcephei commented on a change in pull request #11557: URL: https://github.com/apache/kafka/pull/11557#discussion_r762153447 ## File path: streams/src/main/java/org/apache/kafka/streams/query/PositionBound.java ## @@ -0,0 +1,109 @@ +/* + * Licensed to the Apache Software Found

[GitHub] [kafka] vvcephei commented on a change in pull request #11557: KAFKA-13491: IQv2 framework

vvcephei commented on a change in pull request #11557: URL: https://github.com/apache/kafka/pull/11557#discussion_r762169023 ## File path: streams/src/main/java/org/apache/kafka/streams/query/PositionBound.java ## @@ -0,0 +1,109 @@ +/* + * Licensed to the Apache Software Found

[GitHub] [kafka] vvcephei commented on a change in pull request #11557: KAFKA-13491: IQv2 framework

vvcephei commented on a change in pull request #11557: URL: https://github.com/apache/kafka/pull/11557#discussion_r762154915 ## File path: streams/src/main/java/org/apache/kafka/streams/query/QueryResult.java ## @@ -0,0 +1,210 @@ +/* + * Licensed to the Apache Software Foundati

[GitHub] [kafka] vvcephei commented on pull request #11557: KAFKA-13491: IQv2 framework

vvcephei commented on pull request #11557: URL: https://github.com/apache/kafka/pull/11557#issuecomment-985745412 Thanks again for the review, @cadonna ! I'm tempted to fix that stuff in the current PR, but I'd like to unblock others from rebasing their work on top of this framework. Since

[GitHub] [kafka] vvcephei commented on a change in pull request #11557: KAFKA-13491: IQv2 framework

vvcephei commented on a change in pull request #11557: URL: https://github.com/apache/kafka/pull/11557#discussion_r762163072 ## File path: streams/src/main/java/org/apache/kafka/streams/state/internals/StoreQueryUtils.java ## @@ -0,0 +1,65 @@ +/* + * Licensed to the Apache Sof

[GitHub] [kafka] vvcephei commented on a change in pull request #11557: KAFKA-13491: IQv2 framework

vvcephei commented on a change in pull request #11557: URL: https://github.com/apache/kafka/pull/11557#discussion_r762162581 ## File path: streams/src/main/java/org/apache/kafka/streams/query/QueryResult.java ## @@ -0,0 +1,210 @@ +/* + * Licensed to the Apache Software Foundati

[GitHub] [kafka] vvcephei commented on a change in pull request #11557: KAFKA-13491: IQv2 framework

vvcephei commented on a change in pull request #11557: URL: https://github.com/apache/kafka/pull/11557#discussion_r762154915 ## File path: streams/src/main/java/org/apache/kafka/streams/query/QueryResult.java ## @@ -0,0 +1,210 @@ +/* + * Licensed to the Apache Software Foundati

[GitHub] [kafka] vvcephei commented on a change in pull request #11557: KAFKA-13491: IQv2 framework

vvcephei commented on a change in pull request #11557: URL: https://github.com/apache/kafka/pull/11557#discussion_r762154016 ## File path: streams/src/main/java/org/apache/kafka/streams/query/Query.java ## @@ -0,0 +1,35 @@ +/* + * Licensed to the Apache Software Foundation (ASF

[GitHub] [kafka] vvcephei commented on a change in pull request #11557: KAFKA-13491: IQv2 framework

vvcephei commented on a change in pull request #11557: URL: https://github.com/apache/kafka/pull/11557#discussion_r762153447 ## File path: streams/src/main/java/org/apache/kafka/streams/query/PositionBound.java ## @@ -0,0 +1,109 @@ +/* + * Licensed to the Apache Software Found

[GitHub] [kafka] vvcephei commented on a change in pull request #11557: KAFKA-13491: IQv2 framework

vvcephei commented on a change in pull request #11557: URL: https://github.com/apache/kafka/pull/11557#discussion_r762148745 ## File path: streams/src/test/java/org/apache/kafka/streams/query/PositionTest.java ## @@ -0,0 +1,224 @@ +/* + * Licensed to the Apache Software Founda

[GitHub] [kafka] vvcephei commented on a change in pull request #11557: KAFKA-13491: IQv2 framework

vvcephei commented on a change in pull request #11557: URL: https://github.com/apache/kafka/pull/11557#discussion_r762148443 ## File path: streams/src/main/java/org/apache/kafka/streams/query/Position.java ## @@ -0,0 +1,177 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [kafka] vvcephei commented on a change in pull request #11557: KAFKA-13491: IQv2 framework

vvcephei commented on a change in pull request #11557: URL: https://github.com/apache/kafka/pull/11557#discussion_r762147628 ## File path: streams/src/main/java/org/apache/kafka/streams/query/Position.java ## @@ -0,0 +1,177 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [kafka] vvcephei commented on a change in pull request #11557: KAFKA-13491: IQv2 framework

vvcephei commented on a change in pull request #11557: URL: https://github.com/apache/kafka/pull/11557#discussion_r762147145 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/StateStore.java ## @@ -119,4 +124,32 @@ default void init(final StateStoreContext

[GitHub] [kafka] vvcephei commented on a change in pull request #11557: KAFKA-13491: IQv2 framework

vvcephei commented on a change in pull request #11557: URL: https://github.com/apache/kafka/pull/11557#discussion_r762146538 ## File path: checkstyle/suppressions.xml ## @@ -164,7 +164,7 @@ files="(KafkaStreams|KStreamImpl|KTableImpl).java"/> +

[GitHub] [kafka] vvcephei commented on a change in pull request #11557: KAFKA-13491: IQv2 framework

vvcephei commented on a change in pull request #11557: URL: https://github.com/apache/kafka/pull/11557#discussion_r762146251 ## File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java ## @@ -1716,4 +1725,110 @@ protected void processStreamThread(final Consu

[GitHub] [kafka] hachikuji commented on a change in pull request #11416: KAFKA-13490: Fix createTopics and incrementalAlterConfigs for KRaft mode

hachikuji commented on a change in pull request #11416: URL: https://github.com/apache/kafka/pull/11416#discussion_r762101999 ## File path: core/src/main/scala/kafka/server/ControllerConfigurationValidator.scala ## @@ -0,0 +1,55 @@ +/* + * Licensed to the Apache Software Found

[jira] [Comment Edited] (KAFKA-13505) Kafka Connect should respect Avro 1.10.X enum defaults spec

[ https://issues.apache.org/jira/browse/KAFKA-13505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17453139#comment-17453139 ] Guus De Graeve edited comment on KAFKA-13505 at 12/3/21, 4:58 PM:

[jira] [Commented] (KAFKA-13505) Kafka Connect should respect Avro 1.10.X enum defaults spec

[ https://issues.apache.org/jira/browse/KAFKA-13505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17453139#comment-17453139 ] Guus De Graeve commented on KAFKA-13505: [~jcustenborder] not sure if this reply

[jira] [Updated] (KAFKA-13505) Kafka Connect should respect Avro 1.10.X enum defaults spec

[ https://issues.apache.org/jira/browse/KAFKA-13505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guus De Graeve updated KAFKA-13505: --- Description: We are using Kafka Connect to pipe data from Kafka topics into parquet files on

[GitHub] [kafka] dajac commented on a change in pull request #11456: KAFKA-13351: Add possibility to write kafka headers in Kafka Console Producer

dajac commented on a change in pull request #11456: URL: https://github.com/apache/kafka/pull/11456#discussion_r762081776 ## File path: core/src/main/scala/kafka/tools/ConsoleProducer.scala ## @@ -274,28 +296,74 @@ object ConsoleProducer { parseKey = props.getProperty(

[jira] [Commented] (KAFKA-13505) Kafka Connect should respect Avro 1.10.X enum defaults spec

[ https://issues.apache.org/jira/browse/KAFKA-13505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17453138#comment-17453138 ] Jeremy Custenborder commented on KAFKA-13505: - Not sure if this helps. I ran

[GitHub] [kafka] vvcephei commented on a change in pull request #11557: KAFKA-13491: IQv2 framework

vvcephei commented on a change in pull request #11557: URL: https://github.com/apache/kafka/pull/11557#discussion_r762081422 ## File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java ## @@ -1716,4 +1725,110 @@ protected void processStreamThread(final Consu

[GitHub] [kafka] vvcephei commented on a change in pull request #11557: KAFKA-13491: IQv2 framework

vvcephei commented on a change in pull request #11557: URL: https://github.com/apache/kafka/pull/11557#discussion_r762081149 ## File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java ## @@ -1716,4 +1725,110 @@ protected void processStreamThread(final Consu

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

dajac commented on a change in pull request #11173: URL: https://github.com/apache/kafka/pull/11173#discussion_r762038197 ## File path: core/src/main/scala/kafka/tools/GetOffsetShell.scala ## @@ -222,11 +240,19 @@ object GetOffsetShell { } /** - * Return the partition

[GitHub] [kafka] vvcephei commented on a change in pull request #11557: KAFKA-13491: IQv2 framework

vvcephei commented on a change in pull request #11557: URL: https://github.com/apache/kafka/pull/11557#discussion_r762037170 ## File path: streams/src/main/java/org/apache/kafka/streams/query/StateQueryResult.java ## @@ -0,0 +1,114 @@ +/* + * Licensed to the Apache Software Fo

[GitHub] [kafka] vpapavas commented on a change in pull request #11513: feat: Write and restore position to/from changelog

vpapavas commented on a change in pull request #11513: URL: https://github.com/apache/kafka/pull/11513#discussion_r762030366 ## File path: streams/src/test/java/org/apache/kafka/streams/integration/ConsistencyVectorIntegrationTest.java ## @@ -0,0 +1,236 @@ +/* + * Licensed to

[jira] [Updated] (KAFKA-13505) Kafka Connect should respect Avro 1.10.X enum defaults spec

[ https://issues.apache.org/jira/browse/KAFKA-13505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guus De Graeve updated KAFKA-13505: --- Description: We are using Kafka Connect to pipe data from Kafka topics into +parquet files

[jira] [Created] (KAFKA-13505) Kafka Connect should respect Avro 1.10.X enum defaults spec

Guus De Graeve created KAFKA-13505: -- Summary: Kafka Connect should respect Avro 1.10.X enum defaults spec Key: KAFKA-13505 URL: https://issues.apache.org/jira/browse/KAFKA-13505 Project: Kafka

[jira] [Updated] (KAFKA-13504) Retry connect internal topics' creation in case of InvalidReplicationFactorException

[ https://issues.apache.org/jira/browse/KAFKA-13504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andras Katona updated KAFKA-13504: -- Description: In case the Kafka Broker cluster and the Kafka Connect cluster is started togeth

[jira] [Updated] (KAFKA-13504) Retry connect internal topics' creation in case of InvalidReplicationFactorException

[ https://issues.apache.org/jira/browse/KAFKA-13504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andras Katona updated KAFKA-13504: -- Description: In case the Kafka Broker cluster and the Kafka Connect cluster is started togethe

[jira] [Assigned] (KAFKA-13504) Retry connect internal topics' creation in case of InvalidReplicationFactorException

[ https://issues.apache.org/jira/browse/KAFKA-13504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andras Katona reassigned KAFKA-13504: - Assignee: Andras Katona > Retry connect internal topics' creation in case of > Invalid

[GitHub] [kafka] akatona84 opened a new pull request #11565: KAFKA-13504: Retry connect internal topics' creation in case of InvalidReplicationFactorException

akatona84 opened a new pull request #11565: URL: https://github.com/apache/kafka/pull/11565 *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

[jira] [Created] (KAFKA-13504) Retry connect internal topics' creation in case of InvalidReplicationFactorException

Andras Katona created KAFKA-13504: - Summary: Retry connect internal topics' creation in case of InvalidReplicationFactorException Key: KAFKA-13504 URL: https://issues.apache.org/jira/browse/KAFKA-13504

[GitHub] [kafka] akatona84 commented on pull request #11373: MINOR: Add shebang to gradlewAll

akatona84 commented on pull request #11373: URL: https://github.com/apache/kafka/pull/11373#issuecomment-985545853 @ijuma I've added the same shebang as gradlew has to gradlewAll. Could you check it pls? 🥺 🎅 🎄 😄 -- This is an automated message from the Apache Git Service. To respond t

[GitHub] [kafka] dengziming commented on pull request #11446: MINOR: Delete redudant tmp file

dengziming commented on pull request #11446: URL: https://github.com/apache/kafka/pull/11446#issuecomment-985543052 ping @cmccabe -- 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 co

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

dengziming commented on pull request #10830: URL: https://github.com/apache/kafka/pull/10830#issuecomment-985542755 ping @cmccabe -- 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 co

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

dengziming commented on pull request #11173: URL: https://github.com/apache/kafka/pull/11173#issuecomment-985541598 ping @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 specific comm

[GitHub] [kafka] dajac commented on a change in pull request #11560: KAFKA-7589: Allow configuring network threads per listener

dajac commented on a change in pull request #11560: URL: https://github.com/apache/kafka/pull/11560#discussion_r761930382 ## File path: core/src/main/scala/kafka/network/SocketServer.scala ## @@ -841,16 +974,17 @@ private[kafka] class Processor(val id: Int, Option(metrics.

[jira] [Commented] (KAFKA-13435) Group won't consume partitions added after static member restart

[ https://issues.apache.org/jira/browse/KAFKA-13435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17452990#comment-17452990 ] David Jacot commented on KAFKA-13435: - I don't have the implementation details yet b

[GitHub] [kafka] vpapavas commented on a change in pull request #11513: feat: Write and restore position to/from changelog

vpapavas commented on a change in pull request #11513: URL: https://github.com/apache/kafka/pull/11513#discussion_r761883799 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/ChangelogRecordDeserializationHelper.java ## @@ -0,0 +1,38 @@ +/* + * L

[GitHub] [kafka] vpapavas commented on a change in pull request #11513: feat: Write and restore position to/from changelog

vpapavas commented on a change in pull request #11513: URL: https://github.com/apache/kafka/pull/11513#discussion_r761883799 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/ChangelogRecordDeserializationHelper.java ## @@ -0,0 +1,38 @@ +/* + * L

[GitHub] [kafka] cadonna commented on a change in pull request #11557: KAFKA-13491: IQv2 framework

cadonna commented on a change in pull request #11557: URL: https://github.com/apache/kafka/pull/11557#discussion_r761760939 ## File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java ## @@ -1716,4 +1725,110 @@ protected void processStreamThread(final Consum

[GitHub] [kafka] patrickstuedi commented on a change in pull request #11557: KAFKA-13491: IQv2 framework

patrickstuedi commented on a change in pull request #11557: URL: https://github.com/apache/kafka/pull/11557#discussion_r761770579 ## File path: streams/src/main/java/org/apache/kafka/streams/state/internals/StoreQueryUtils.java ## @@ -0,0 +1,65 @@ +/* + * Licensed to the Apach

[GitHub] [kafka] dajac merged pull request #11539: MINOR: Update doc for 3.1

dajac merged pull request #11539: URL: https://github.com/apache/kafka/pull/11539 -- 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...