[jira] [Commented] (KAFKA-7181) Kafka Streams State stuck in rebalancing after one of the StreamThread encounters IllegalStateException

2019-10-30 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963638#comment-16963638 ] Sophie Blee-Goldman commented on KAFKA-7181: Left a note on the other ticket, but just to

[jira] [Updated] (KAFKA-9073) Kafka Streams State stuck in rebalancing after one of the StreamThread encounters java.lang.IllegalStateException: No current assignment for partition

2019-10-30 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9073: --- Fix Version/s: 2.4.0 > Kafka Streams State stuck in rebalancing after one of the

[jira] [Commented] (KAFKA-9073) Kafka Streams State stuck in rebalancing after one of the StreamThread encounters java.lang.IllegalStateException: No current assignment for partition

2019-10-30 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963631#comment-16963631 ] Sophie Blee-Goldman commented on KAFKA-9073: It looks like this was actually found and fixed

[jira] [Updated] (KAFKA-8630) Unit testing a streams processor with a WindowStore throws a ClassCastException

2019-10-30 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8630: --- Priority: Critical (was: Major) > Unit testing a streams processor with a

[jira] [Updated] (KAFKA-8630) Unit testing a streams processor with a WindowStore throws a ClassCastException

2019-10-30 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8630: --- Fix Version/s: 2.5.0 > Unit testing a streams processor with a WindowStore throws a

[jira] [Commented] (KAFKA-8972) KafkaConsumer.unsubscribe could leave inconsistent user rebalance callback state

2019-10-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963603#comment-16963603 ] ASF GitHub Bot commented on KAFKA-8972: --- ableegoldman commented on pull request #7620: KAFKA-8972

[jira] [Assigned] (KAFKA-9069) Flaky Test AdminClientIntegrationTest.testCreatePartitions

2019-10-30 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-9069: - Assignee: huxihx > Flaky Test AdminClientIntegrationTest.testCreatePartitions >

[jira] [Commented] (KAFKA-9069) Flaky Test AdminClientIntegrationTest.testCreatePartitions

2019-10-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963592#comment-16963592 ] ASF GitHub Bot commented on KAFKA-9069: --- huxihx commented on pull request #7619: KAFKA-9069: Flaky

[jira] [Assigned] (KAFKA-9113) Clean up task management

2019-10-30 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-9113: -- Assignee: Sophie Blee-Goldman > Clean up task management >

[jira] [Commented] (KAFKA-9025) ZkSecurityMigrator not working with zookeeper chroot

2019-10-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963581#comment-16963581 ] ASF GitHub Bot commented on KAFKA-9025: --- huxihx commented on pull request #7618: KAFKA-9025:

[jira] [Assigned] (KAFKA-9025) ZkSecurityMigrator not working with zookeeper chroot

2019-10-30 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-9025: - Assignee: huxihx > ZkSecurityMigrator not working with zookeeper chroot >

[jira] [Resolved] (KAFKA-9092) Kafka Streams Upgrade Magic v0 does not support record headers

2019-10-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9092. Resolution: Duplicate > Kafka Streams Upgrade Magic v0 does not support record headers >

[jira] [Commented] (KAFKA-9092) Kafka Streams Upgrade Magic v0 does not support record headers

2019-10-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963550#comment-16963550 ] Matthias J. Sax commented on KAFKA-9092: [~wxmimperio] – I am closing this a duplicate for now –

[jira] [Reopened] (KAFKA-8972) KafkaConsumer.unsubscribe could leave inconsistent user rebalance callback state

2019-10-30 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reopened KAFKA-8972: > KafkaConsumer.unsubscribe could leave inconsistent user rebalance callback > state >

[jira] [Commented] (KAFKA-8972) KafkaConsumer.unsubscribe could leave inconsistent user rebalance callback state

2019-10-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963543#comment-16963543 ] ASF GitHub Bot commented on KAFKA-8972: --- abbccdda commented on pull request #7617: KAFKA-8972: bug

[jira] [Commented] (KAFKA-9121) Mirror Maker 2.0 doesn't handle the topic names in consumer checkpoints properly when topic name contain separator

2019-10-30 Thread Ryanne Dolan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963519#comment-16963519 ] Ryanne Dolan commented on KAFKA-9121: - Hmm, I think we'll always run into such issues if the

[jira] [Created] (KAFKA-9121) Mirror Maker 2.0 doesn't handle the topic names in consumer checkpoints properly when topic name contain separator

2019-10-30 Thread Jakub Scholz (Jira)
Jakub Scholz created KAFKA-9121: --- Summary: Mirror Maker 2.0 doesn't handle the topic names in consumer checkpoints properly when topic name contain separator Key: KAFKA-9121 URL:

[jira] [Commented] (KAFKA-9121) Mirror Maker 2.0 doesn't handle the topic names in consumer checkpoints properly when topic name contain separator

2019-10-30 Thread Jakub Scholz (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963466#comment-16963466 ] Jakub Scholz commented on KAFKA-9121: - CC [~ryannedolan] > Mirror Maker 2.0 doesn't handle the topic

[jira] [Commented] (KAFKA-9120) Convert ./bin/kafka-reassign-partitions.sh to use KIP-455

2019-10-30 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963463#comment-16963463 ] Ismael Juma commented on KAFKA-9120: [~steverod] has a PR for this. > Convert

[jira] [Commented] (KAFKA-9093) NullPointerException in KafkaConsumer with group.instance.id

2019-10-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963436#comment-16963436 ] ASF GitHub Bot commented on KAFKA-9093: --- guozhangwang commented on pull request #7590: KAFKA-9093:

[jira] [Created] (KAFKA-9120) Convert ./bin/kafka-reassign-partitions.sh to use KIP-455

2019-10-30 Thread Colin McCabe (Jira)
Colin McCabe created KAFKA-9120: --- Summary: Convert ./bin/kafka-reassign-partitions.sh to use KIP-455 Key: KAFKA-9120 URL: https://issues.apache.org/jira/browse/KAFKA-9120 Project: Kafka Issue

[jira] [Assigned] (KAFKA-9082) Move ConfigCommand to use KafkaAdminClient APIs

2019-10-30 Thread Colin McCabe (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin McCabe reassigned KAFKA-9082: --- Assignee: Brian Byrne > Move ConfigCommand to use KafkaAdminClient APIs >

[jira] [Updated] (KAFKA-9118) LogDirFailureHandler shouldn't use Zookeeper

2019-10-30 Thread Colin McCabe (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin McCabe updated KAFKA-9118: Parent: KAFKA-9119 Issue Type: Sub-task (was: Improvement) > LogDirFailureHandler

[jira] [Updated] (KAFKA-9082) Move ConfigCommand to use KafkaAdminClient APIs

2019-10-30 Thread Colin McCabe (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin McCabe updated KAFKA-9082: Parent: KAFKA-9119 Issue Type: Sub-task (was: Improvement) > Move ConfigCommand to use

[jira] [Created] (KAFKA-9119) KIP-500: Replace ZooKeeper with a Metadata Quorum

2019-10-30 Thread Colin McCabe (Jira)
Colin McCabe created KAFKA-9119: --- Summary: KIP-500: Replace ZooKeeper with a Metadata Quorum Key: KAFKA-9119 URL: https://issues.apache.org/jira/browse/KAFKA-9119 Project: Kafka Issue Type:

[jira] [Assigned] (KAFKA-9080) System Test Failure: MessageFormatChangeTest.testCompatibilty

2019-10-30 Thread Manikumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar reassigned KAFKA-9080: Assignee: Tu Tran  looks like test is failing after [https://github.com/apache/kafka/pull/7167]  

[jira] [Updated] (KAFKA-9073) Kafka Streams State stuck in rebalancing after one of the StreamThread encounters java.lang.IllegalStateException: No current assignment for partition

2019-10-30 Thread amuthan Ganeshan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] amuthan Ganeshan updated KAFKA-9073: Attachment: KAFKA-9073.log > Kafka Streams State stuck in rebalancing after one of the

[jira] [Updated] (KAFKA-9073) Kafka Streams State stuck in rebalancing after one of the StreamThread encounters java.lang.IllegalStateException: No current assignment for partition

2019-10-30 Thread amuthan Ganeshan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] amuthan Ganeshan updated KAFKA-9073: Attachment: (was: KAFKA-9073.log) > Kafka Streams State stuck in rebalancing after one

[jira] [Commented] (KAFKA-9073) Kafka Streams State stuck in rebalancing after one of the StreamThread encounters java.lang.IllegalStateException: No current assignment for partition

2019-10-30 Thread amuthan Ganeshan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963303#comment-16963303 ] amuthan Ganeshan commented on KAFKA-9073: - Okay, Today morning I got the same error in my staging

[jira] [Updated] (KAFKA-9073) Kafka Streams State stuck in rebalancing after one of the StreamThread encounters java.lang.IllegalStateException: No current assignment for partition

2019-10-30 Thread amuthan Ganeshan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] amuthan Ganeshan updated KAFKA-9073: Attachment: KAFKA-9073.log > Kafka Streams State stuck in rebalancing after one of the

[jira] [Commented] (KAFKA-6542) Tables should trigger joins too, not just streams

2019-10-30 Thread Chad Preisler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963282#comment-16963282 ] Chad Preisler commented on KAFKA-6542: -- I'm very new to the stream API code, but it seems like this

[jira] [Updated] (KAFKA-8980) Refactor State-Store-level Metrics

2019-10-30 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8980: --- Fix Version/s: 2.5.0 > Refactor State-Store-level Metrics > -- > >

[jira] [Resolved] (KAFKA-8980) Refactor State-Store-level Metrics

2019-10-30 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8980. Resolution: Fixed > Refactor State-Store-level Metrics > -- > >

[jira] [Updated] (KAFKA-8980) Refactor State-Store-level Metrics

2019-10-30 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8980: --- Affects Version/s: 2.5.0 > Refactor State-Store-level Metrics > -- >

[jira] [Commented] (KAFKA-8980) Refactor State-Store-level Metrics

2019-10-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963187#comment-16963187 ] ASF GitHub Bot commented on KAFKA-8980: --- bbejeck commented on pull request #7584: KAFKA-8980:

[jira] [Updated] (KAFKA-8677) Flakey test GroupEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

2019-10-30 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8677: --- Priority: Blocker (was: Major) > Flakey test >

[jira] [Commented] (KAFKA-9025) ZkSecurityMigrator not working with zookeeper chroot

2019-10-30 Thread Laurent Millet (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963096#comment-16963096 ] Laurent Millet commented on KAFKA-9025: --- [~huxi_2b] thanks for the reminder, I had obviously

[jira] [Updated] (KAFKA-9079) System Test Failure: TransactionsTest

2019-10-30 Thread Manikumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-9079: - Docs Text: This looks like flaky test failures. Moving to 2.5.0 Fix Version/s: (was: 2.4.0)

[jira] [Updated] (KAFKA-9072) Add Section to Streams Developer Guide for Topology Naming (KIP-307)

2019-10-30 Thread Manikumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-9072: - Fix Version/s: (was: 2.4.0) 2.5.0 > Add Section to Streams Developer Guide for

[jira] [Updated] (KAFKA-9118) LogDirFailureHandler shouldn't use Zookeeper

2019-10-30 Thread Viktor Somogyi-Vass (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Viktor Somogyi-Vass updated KAFKA-9118: --- Description: As described in

[jira] [Commented] (KAFKA-6985) Error connection between cluster node

2019-10-30 Thread Fernando Iury Alves Costa (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963013#comment-16963013 ] Fernando Iury Alves Costa commented on KAFKA-6985: -- I'm having the same issue running 

[jira] [Created] (KAFKA-9118) LogDirFailureHandler shouldn't use Zookeeper

2019-10-30 Thread Viktor Somogyi-Vass (Jira)
Viktor Somogyi-Vass created KAFKA-9118: -- Summary: LogDirFailureHandler shouldn't use Zookeeper Key: KAFKA-9118 URL: https://issues.apache.org/jira/browse/KAFKA-9118 Project: Kafka Issue

[jira] [Assigned] (KAFKA-9117) Add active-process-ratio Metric

2019-10-30 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reassigned KAFKA-9117: Assignee: Bruno Cadonna > Add active-process-ratio Metric >

[jira] [Created] (KAFKA-9117) Add active-process-ratio Metric

2019-10-30 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-9117: Summary: Add active-process-ratio Metric Key: KAFKA-9117 URL: https://issues.apache.org/jira/browse/KAFKA-9117 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-9095) Kafka Cluster Issue when API Version =1

2019-10-30 Thread Mantesh Janagond (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962965#comment-16962965 ] Mantesh Janagond commented on KAFKA-9095: - Any updates? > Kafka Cluster Issue when API Version

[jira] [Created] (KAFKA-9116) Improve navigation on the kafka site

2019-10-30 Thread Viktor Somogyi-Vass (Jira)
Viktor Somogyi-Vass created KAFKA-9116: -- Summary: Improve navigation on the kafka site Key: KAFKA-9116 URL: https://issues.apache.org/jira/browse/KAFKA-9116 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-9086) Refactor Processor Node Streams Metrics

2019-10-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962914#comment-16962914 ] ASF GitHub Bot commented on KAFKA-9086: --- cadonna commented on pull request #7615: KAFKA-9086:

[jira] [Created] (KAFKA-9115) Add Roll-up Throughput Sensor for Processing on Source Nodes

2019-10-30 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-9115: Summary: Add Roll-up Throughput Sensor for Processing on Source Nodes Key: KAFKA-9115 URL: https://issues.apache.org/jira/browse/KAFKA-9115 Project: Kafka

[jira] [Assigned] (KAFKA-9115) Add Roll-up Throughput Sensor for Processing on Source Nodes

2019-10-30 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reassigned KAFKA-9115: Assignee: Bruno Cadonna > Add Roll-up Throughput Sensor for Processing on Source Nodes >

[jira] [Updated] (KAFKA-9086) Refactor Processor Node Streams Metrics

2019-10-30 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-9086: - Description: Refactor processor node metrics as described in KIP-444. (was: Remove

[jira] [Assigned] (KAFKA-9034) kafka-run-class.sh will fail if JAVA_HOME has space

2019-10-30 Thread Csenge Maruzsi (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Csenge Maruzsi reassigned KAFKA-9034: - Assignee: Csenge Maruzsi > kafka-run-class.sh will fail if JAVA_HOME has space >

[jira] [Assigned] (KAFKA-9015) Unify metric names

2019-10-30 Thread Csenge Maruzsi (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Csenge Maruzsi reassigned KAFKA-9015: - Assignee: Csenge Maruzsi (was: Viktor Somogyi-Vass) > Unify metric names >

[jira] [Assigned] (KAFKA-8682) Add meter for group rebalance rate

2019-10-30 Thread Viktor Somogyi-Vass (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Viktor Somogyi-Vass reassigned KAFKA-8682: -- Assignee: Viktor Somogyi-Vass > Add meter for group rebalance rate >

[jira] [Commented] (KAFKA-9069) Flaky Test AdminClientIntegrationTest.testCreatePartitions

2019-10-30 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962816#comment-16962816 ] huxihx commented on KAFKA-9069: ---

[jira] [Commented] (KAFKA-4388) Connect key and value converters are listed without default values

2019-10-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962774#comment-16962774 ] ASF GitHub Bot commented on KAFKA-4388: --- evis commented on pull request #3435: KAFKA-4388