[jira] [Created] (KAFKA-7691) Encypt-then-MAC Delegation token metadata

Attila Sasvari created KAFKA-7691: - Summary: Encypt-then-MAC Delegation token metadata Key: KAFKA-7691 URL: https://issues.apache.org/jira/browse/KAFKA-7691 Project: Kafka Issue Type: Improve

[jira] [Assigned] (KAFKA-7691) Encypt-then-MAC Delegation token metadata

[ https://issues.apache.org/jira/browse/KAFKA-7691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Attila Sasvari reassigned KAFKA-7691: - Assignee: Attila Sasvari > Encypt-then-MAC Delegation token metadata > -

[jira] [Created] (KAFKA-7696) kafka-delegation-tokens.sh using a config file that contains security.protocol=SASL_PLAINTEXT throws OutOfMemoryError if it tries to connect to an SSL-enabled secured bro

Attila Sasvari created KAFKA-7696: - Summary: kafka-delegation-tokens.sh using a config file that contains security.protocol=SASL_PLAINTEXT throws OutOfMemoryError if it tries to connect to an SSL-enabled secured broker Key: KAFKA

[jira] [Assigned] (KAFKA-7696) kafka-delegation-tokens.sh using a config file that contains security.protocol=SASL_PLAINTEXT throws OutOfMemoryError if it tries to connect to an SSL-enabled secured br

[ https://issues.apache.org/jira/browse/KAFKA-7696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Attila Sasvari reassigned KAFKA-7696: - Assignee: Viktor Somogyi > kafka-delegation-tokens.sh using a config file that contains

[jira] [Commented] (KAFKA-7696) kafka-delegation-tokens.sh using a config file that contains security.protocol=SASL_PLAINTEXT throws OutOfMemoryError if it tries to connect to an SSL-enabled secured b

[ https://issues.apache.org/jira/browse/KAFKA-7696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16708633#comment-16708633 ] Attila Sasvari commented on KAFKA-7696: --- Thanks [~omkreddy]! Resolving this as a du

[jira] [Resolved] (KAFKA-7696) kafka-delegation-tokens.sh using a config file that contains security.protocol=SASL_PLAINTEXT throws OutOfMemoryError if it tries to connect to an SSL-enabled secured br

[ https://issues.apache.org/jira/browse/KAFKA-7696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Attila Sasvari resolved KAFKA-7696. --- Resolution: Duplicate > kafka-delegation-tokens.sh using a config file that contains > secur

[jira] [Assigned] (KAFKA-7631) NullPointerException when SCRAM is allowed bu ScramLoginModule is not in broker's jaas.conf

[ https://issues.apache.org/jira/browse/KAFKA-7631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Attila Sasvari reassigned KAFKA-7631: - Assignee: Viktor Somogyi (was: Attila Sasvari) > NullPointerException when SCRAM is all

[jira] [Created] (KAFKA-7752) zookeeper-security-migration.sh does not remove ACL on kafka-acl-extended

Attila Sasvari created KAFKA-7752: - Summary: zookeeper-security-migration.sh does not remove ACL on kafka-acl-extended Key: KAFKA-7752 URL: https://issues.apache.org/jira/browse/KAFKA-7752 Project: Ka

[jira] [Assigned] (KAFKA-7752) zookeeper-security-migration.sh does not remove ACL on kafka-acl-extended

[ https://issues.apache.org/jira/browse/KAFKA-7752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Attila Sasvari reassigned KAFKA-7752: - Assignee: Attila Sasvari > zookeeper-security-migration.sh does not remove ACL on kafka-

[jira] [Commented] (KAFKA-7752) zookeeper-security-migration.sh does not remove ACL on kafka-acl-extended

[ https://issues.apache.org/jira/browse/KAFKA-7752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16726830#comment-16726830 ] Attila Sasvari commented on KAFKA-7752: --- In kafka.zk.ZkData class, ZkAclStore.secur

[jira] [Created] (KAFKA-7813) JmxTool throws NPE when --object-name is omitted

Attila Sasvari created KAFKA-7813: - Summary: JmxTool throws NPE when --object-name is omitted Key: KAFKA-7813 URL: https://issues.apache.org/jira/browse/KAFKA-7813 Project: Kafka Issue Type:

[jira] [Assigned] (KAFKA-6332) Kafka system tests should use nc instead of log grep to detect start-up

[ https://issues.apache.org/jira/browse/KAFKA-6332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Attila Sasvari reassigned KAFKA-6332: - Assignee: (was: Attila Sasvari) > Kafka system tests should use nc instead of log gr

[jira] [Commented] (KAFKA-6332) Kafka system tests should use nc instead of log grep to detect start-up

[ https://issues.apache.org/jira/browse/KAFKA-6332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16791592#comment-16791592 ] Attila Sasvari commented on KAFKA-6332: --- Feel free to take it over. > Kafka system

[jira] [Created] (KAFKA-7289) Performance tools should allow user to specify output type

Attila Sasvari created KAFKA-7289: - Summary: Performance tools should allow user to specify output type Key: KAFKA-7289 URL: https://issues.apache.org/jira/browse/KAFKA-7289 Project: Kafka Is

[jira] [Commented] (KAFKA-7289) Performance tools should allow user to specify output type

[ https://issues.apache.org/jira/browse/KAFKA-7289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16579719#comment-16579719 ] Attila Sasvari commented on KAFKA-7289: --- It is a generalization of KAFKA-1939. > P

[jira] [Assigned] (KAFKA-7289) Performance tools should allow user to specify output type

[ https://issues.apache.org/jira/browse/KAFKA-7289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Attila Sasvari reassigned KAFKA-7289: - Assignee: Attila Sasvari > Performance tools should allow user to specify output type >

[jira] [Commented] (KAFKA-7289) Performance tools should allow user to specify output type

[ https://issues.apache.org/jira/browse/KAFKA-7289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16580792#comment-16580792 ] Attila Sasvari commented on KAFKA-7289: --- - I will start the KIP soon. It might be e

[jira] [Commented] (KAFKA-4544) Add system tests for delegation token based authentication

[ https://issues.apache.org/jira/browse/KAFKA-4544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16598557#comment-16598557 ] Attila Sasvari commented on KAFKA-4544: --- Do you have the capacity to work on this [

[jira] [Assigned] (KAFKA-4544) Add system tests for delegation token based authentication

[ https://issues.apache.org/jira/browse/KAFKA-4544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Attila Sasvari reassigned KAFKA-4544: - Assignee: Attila Sasvari (was: Manikumar) > Add system tests for delegation token based

[jira] [Commented] (KAFKA-4544) Add system tests for delegation token based authentication

[ https://issues.apache.org/jira/browse/KAFKA-4544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16604530#comment-16604530 ] Attila Sasvari commented on KAFKA-4544: --- [~omkreddy] thanks a lot! - I started to w

[jira] [Commented] (KAFKA-4544) Add system tests for delegation token based authentication

[ https://issues.apache.org/jira/browse/KAFKA-4544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16605944#comment-16605944 ] Attila Sasvari commented on KAFKA-4544: --- [~omkreddy] thanks for the info, I extende

[jira] [Commented] (KAFKA-4544) Add system tests for delegation token based authentication

[ https://issues.apache.org/jira/browse/KAFKA-4544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16607140#comment-16607140 ] Attila Sasvari commented on KAFKA-4544: --- Thanks [~omkreddy], I see your point. Toda

[jira] [Assigned] (KAFKA-7392) Allow to specify subnet for Docker containers using standard CIDR notation

[ https://issues.apache.org/jira/browse/KAFKA-7392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Attila Sasvari reassigned KAFKA-7392: - Assignee: Attila Sasvari > Allow to specify subnet for Docker containers using standard

[jira] [Created] (KAFKA-7392) Allow to specify subnet for Docker containers using standard CIDR notation

Attila Sasvari created KAFKA-7392: - Summary: Allow to specify subnet for Docker containers using standard CIDR notation Key: KAFKA-7392 URL: https://issues.apache.org/jira/browse/KAFKA-7392 Project: K

[jira] [Created] (KAFKA-7418) Add '--help' option to all available Kafka CLI commands

Attila Sasvari created KAFKA-7418: - Summary: Add '--help' option to all available Kafka CLI commands Key: KAFKA-7418 URL: https://issues.apache.org/jira/browse/KAFKA-7418 Project: Kafka Issu

[jira] [Commented] (KAFKA-7418) Add '--help' option to all available Kafka CLI commands

[ https://issues.apache.org/jira/browse/KAFKA-7418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16620459#comment-16620459 ] Attila Sasvari commented on KAFKA-7418: --- [~mrsrinivas] sure, it is totally fine wit

[jira] [Commented] (KAFKA-7418) Add '--help' option to all available Kafka CLI commands

[ https://issues.apache.org/jira/browse/KAFKA-7418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16620470#comment-16620470 ] Attila Sasvari commented on KAFKA-7418: --- - Created a KIP: https://cwiki.apache.org

[jira] [Commented] (KAFKA-7418) Add '--help' option to all available Kafka CLI commands

[ https://issues.apache.org/jira/browse/KAFKA-7418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16620538#comment-16620538 ] Attila Sasvari commented on KAFKA-7418: --- - I started a discussion thread about the

[jira] [Created] (KAFKA-7455) JmxTool cannot connect to an SSL-enabled JMX RMI port

Attila Sasvari created KAFKA-7455: - Summary: JmxTool cannot connect to an SSL-enabled JMX RMI port Key: KAFKA-7455 URL: https://issues.apache.org/jira/browse/KAFKA-7455 Project: Kafka Issue T

[jira] [Assigned] (KAFKA-7631) NullPointerException when SCRAM is allowed bu ScramLoginModule is not in broker's jaas.conf

[ https://issues.apache.org/jira/browse/KAFKA-7631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Attila Sasvari reassigned KAFKA-7631: - Assignee: Attila Sasvari > NullPointerException when SCRAM is allowed bu ScramLoginModul

[jira] [Commented] (KAFKA-6332) Kafka system tests should use nc instead of log grep to detect start-up

[ https://issues.apache.org/jira/browse/KAFKA-6332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16368328#comment-16368328 ] Attila Sasvari commented on KAFKA-6332: --- [~ijuma] I'd like to work on this task, can

[jira] [Commented] (KAFKA-6332) Kafka system tests should use nc instead of log grep to detect start-up

[ https://issues.apache.org/jira/browse/KAFKA-6332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16369119#comment-16369119 ] Attila Sasvari commented on KAFKA-6332: --- [~hachikuji] many thanks! I created a PR an

[jira] [Created] (KAFKA-6703) MirrorMaker cannot make progress when any matched topic from a whitelist regexp has -1 leader

Attila Sasvari created KAFKA-6703: - Summary: MirrorMaker cannot make progress when any matched topic from a whitelist regexp has -1 leader Key: KAFKA-6703 URL: https://issues.apache.org/jira/browse/KAFKA-6703

[jira] [Commented] (KAFKA-6703) MirrorMaker cannot make progress when any matched topic from a whitelist regexp has -1 leader

[ https://issues.apache.org/jira/browse/KAFKA-6703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16410078#comment-16410078 ] Attila Sasvari commented on KAFKA-6703: --- There is a call to [ensureCoordinatorReady

[jira] [Updated] (KAFKA-6703) MirrorMaker cannot make progress when any matched topic from a whitelist regexp has -1 leader

[ https://issues.apache.org/jira/browse/KAFKA-6703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Attila Sasvari updated KAFKA-6703: -- Description: Scenario: - MM whitelabel regexp matches multiple topics - destination cluster ha

[jira] [Commented] (KAFKA-6699) When one of two Kafka nodes are dead, streaming API cannot handle messaging

[ https://issues.apache.org/jira/browse/KAFKA-6699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16411222#comment-16411222 ] Attila Sasvari commented on KAFKA-6699: --- [~habdank] have you tried to specify a diff

[jira] [Commented] (KAFKA-6699) When one of two Kafka nodes are dead, streaming API cannot handle messaging

[ https://issues.apache.org/jira/browse/KAFKA-6699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16411454#comment-16411454 ] Attila Sasvari commented on KAFKA-6699: --- [~habdank] just a quick question: is the re

[jira] [Resolved] (KAFKA-6703) MirrorMaker cannot make progress when any matched topic from a whitelist regexp has -1 leader

[ https://issues.apache.org/jira/browse/KAFKA-6703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Attila Sasvari resolved KAFKA-6703. --- Resolution: Not A Bug It turned out I forgot to set proper replication factor for {{__consume

[jira] [Commented] (KAFKA-6799) Consumer livelock during consumer group rebalance

[ https://issues.apache.org/jira/browse/KAFKA-6799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16443921#comment-16443921 ] Attila Sasvari commented on KAFKA-6799: --- [~phdezann] thanks for reporting this issue

[jira] [Comment Edited] (KAFKA-6799) Consumer livelock during consumer group rebalance

[ https://issues.apache.org/jira/browse/KAFKA-6799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16443921#comment-16443921 ] Attila Sasvari edited comment on KAFKA-6799 at 4/19/18 3:00 PM:

[jira] [Commented] (KAFKA-6799) Consumer livelock during consumer group rebalance

[ https://issues.apache.org/jira/browse/KAFKA-6799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16445529#comment-16445529 ] Attila Sasvari commented on KAFKA-6799: --- [~phdezann] do you have any update? I have

[jira] [Assigned] (KAFKA-6799) Consumer livelock during consumer group rebalance

[ https://issues.apache.org/jira/browse/KAFKA-6799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Attila Sasvari reassigned KAFKA-6799: - Assignee: Attila Sasvari > Consumer livelock during consumer group rebalance > --

[jira] [Resolved] (KAFKA-6799) Consumer livelock during consumer group rebalance

[ https://issues.apache.org/jira/browse/KAFKA-6799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Attila Sasvari resolved KAFKA-6799. --- Resolution: Information Provided > Consumer livelock during consumer group rebalance > ---

[jira] [Commented] (KAFKA-6822) Kafka Consumer 0.10.2.1 can not normally read data from Kafka 1.0.0

[ https://issues.apache.org/jira/browse/KAFKA-6822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16451772#comment-16451772 ] Attila Sasvari commented on KAFKA-6822: --- [~phil.mikhailov] I wonder if it is related

[jira] [Updated] (KAFKA-6822) Kafka Consumer 0.10.2.1 can not normally read data from Kafka 1.0.0

[ https://issues.apache.org/jira/browse/KAFKA-6822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Attila Sasvari updated KAFKA-6822: -- Component/s: streams > Kafka Consumer 0.10.2.1 can not normally read data from Kafka 1.0.0 > ---

[jira] [Created] (KAFKA-6883) KafkaShortnamer should allow to convert Kerberos principal name to upper case user name

Attila Sasvari created KAFKA-6883: - Summary: KafkaShortnamer should allow to convert Kerberos principal name to upper case user name Key: KAFKA-6883 URL: https://issues.apache.org/jira/browse/KAFKA-6883

[jira] [Commented] (KAFKA-6883) KafkaShortnamer should allow to convert Kerberos principal name to upper case user name

[ https://issues.apache.org/jira/browse/KAFKA-6883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16467207#comment-16467207 ] Attila Sasvari commented on KAFKA-6883: --- HADOOP-13984 is a similar issue. > KafkaSh

[jira] [Assigned] (KAFKA-6884) ConsumerGroupCommand should use new AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-6884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Attila Sasvari reassigned KAFKA-6884: - Assignee: Attila Sasvari > ConsumerGroupCommand should use new AdminClient >

[jira] [Commented] (KAFKA-6884) ConsumerGroupCommand should use new AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-6884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16468881#comment-16468881 ] Attila Sasvari commented on KAFKA-6884: --- [~hachikuji] consumer-groups.sh currently u

[jira] [Commented] (KAFKA-6884) ConsumerGroupCommand should use new AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-6884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16470680#comment-16470680 ] Attila Sasvari commented on KAFKA-6884: --- [~hachikuji] thanks for the additional info

[jira] [Commented] (KAFKA-6884) ConsumerGroupCommand should use new AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-6884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16471932#comment-16471932 ] Attila Sasvari commented on KAFKA-6884: --- [~hachikuji] Thanks, I downloaded the pull

[jira] [Commented] (KAFKA-6884) ConsumerGroupCommand should use new AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-6884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16472041#comment-16472041 ] Attila Sasvari commented on KAFKA-6884: --- It seems assignmentStrategy is also needed.

[jira] [Commented] (KAFKA-6884) ConsumerGroupCommand should use new AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-6884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16475751#comment-16475751 ] Attila Sasvari commented on KAFKA-6884: --- Thanks [~hachikuji]. I have seen the pull r

[jira] [Commented] (KAFKA-6884) ConsumerGroupCommand should use new AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-6884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16476020#comment-16476020 ] Attila Sasvari commented on KAFKA-6884: --- - tests that verify timeouts pass after mak

[jira] [Updated] (KAFKA-6884) ConsumerGroupCommand should use new AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-6884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Attila Sasvari updated KAFKA-6884: -- Description: Now that we have KIP-222, we should update ConsumerGroupCommand to use the new Admi

[jira] [Created] (KAFKA-6960) Remove the methods from the internal Scala AdminClient that are provided by the new AdminClient

Attila Sasvari created KAFKA-6960: - Summary: Remove the methods from the internal Scala AdminClient that are provided by the new AdminClient Key: KAFKA-6960 URL: https://issues.apache.org/jira/browse/KAFKA-6960

[jira] [Commented] (KAFKA-6884) ConsumerGroupCommand should use new AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-6884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16503506#comment-16503506 ] Attila Sasvari commented on KAFKA-6884: --- Latest test results: - JDK 8 and Scala 2.1

[jira] [Assigned] (KAFKA-7173) Update BrokerApiVersionsCommand to use new AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-7173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Attila Sasvari reassigned KAFKA-7173: - Assignee: Attila Sasvari > Update BrokerApiVersionsCommand to use new AdminClient >

[jira] [Commented] (KAFKA-6884) ConsumerGroupCommand should use new AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-6884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549082#comment-16549082 ] Attila Sasvari commented on KAFKA-6884: --- pull request was merged, thanks for the re

[jira] [Assigned] (KAFKA-6960) Remove the methods from the internal Scala AdminClient that are provided by the new AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-6960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Attila Sasvari reassigned KAFKA-6960: - Assignee: Attila Sasvari > Remove the methods from the internal Scala AdminClient that a

[jira] [Commented] (KAFKA-7159) mark configuration files in confluent-kafka RPM SPEC file

[ https://issues.apache.org/jira/browse/KAFKA-7159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16550735#comment-16550735 ] Attila Sasvari commented on KAFKA-7159: --- - Are you sure you filed the JIRA to the p

[jira] [Resolved] (KAFKA-7159) mark configuration files in confluent-kafka RPM SPEC file

[ https://issues.apache.org/jira/browse/KAFKA-7159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Attila Sasvari resolved KAFKA-7159. --- Resolution: Won't Fix > mark configuration files in confluent-kafka RPM SPEC file > -

[jira] [Commented] (KAFKA-7134) KafkaLog4jAppender - Appender exceptions are propagated to caller

[ https://issues.apache.org/jira/browse/KAFKA-7134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16558325#comment-16558325 ] Attila Sasvari commented on KAFKA-7134: --- [~venkatpotru] please note if the underlyi