[jira] [Created] (KAFKA-7233) InMemoryKeyValueStore is not thread-safe for Interactive Queries

2018-08-01 Thread Hashan Gayasri Udugahapattuwa (JIRA)
Hashan Gayasri Udugahapattuwa created KAFKA-7233: Summary: InMemoryKeyValueStore is not thread-safe for Interactive Queries Key: KAFKA-7233 URL: https://issues.apache.org/jira/browse/KAFKA-7233

[jira] [Created] (KAFKA-7232) Allow kafka-topics.sh to take brokerid as parameter to show partitions associated with it

2018-08-01 Thread Ratish Ravindran (JIRA)
Ratish Ravindran created KAFKA-7232: --- Summary: Allow kafka-topics.sh to take brokerid as parameter to show partitions associated with it Key: KAFKA-7232 URL: https://issues.apache.org/jira/browse/KAFKA-7232

[jira] [Commented] (KAFKA-7225) Kafka Connect ConfigProvider not invoked before validation

2018-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16566297#comment-16566297 ] ASF GitHub Bot commented on KAFKA-7225: --- rayokota opened a new pull request #5445: KAFKA-7225 -

[jira] [Updated] (KAFKA-5863) Potential null dereference in DistributedHerder#reconfigureConnector()

2018-08-01 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5863: -- Description: Here is the call chain: {code}

[jira] [Comment Edited] (KAFKA-6303) Potential lack of synchronization in NioEchoServer#AcceptorThread

2018-08-01 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16333251#comment-16333251 ] Ted Yu edited comment on KAFKA-6303 at 8/2/18 1:48 AM: --- +1 from me . was (Author:

[jira] [Commented] (KAFKA-7049) InternalTopicIntegrationTest sometimes fails

2018-08-01 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16566242#comment-16566242 ] Ted Yu commented on KAFKA-7049: --- Haven't seen this error for a little while. >

[jira] [Commented] (KAFKA-7175) Make version checking logic more flexible in streams_upgrade_test.py

2018-08-01 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16566241#comment-16566241 ] Ted Yu commented on KAFKA-7175: --- What Ray said sounds feasible. > Make version checking logic more

[jira] [Assigned] (KAFKA-7225) Kafka Connect ConfigProvider not invoked before validation

2018-08-01 Thread Robert Yokota (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Yokota reassigned KAFKA-7225: Assignee: Robert Yokota > Kafka Connect ConfigProvider not invoked before validation >

[jira] [Commented] (KAFKA-4701) Allow kafka brokers to dynamically reload truststore without restarting.

2018-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16566017#comment-16566017 ] ASF GitHub Bot commented on KAFKA-4701: --- allenxiang closed pull request #2446: KAFKA-4701: Add

[jira] [Commented] (KAFKA-7231) NetworkClient.newClientRequest() ignores custom request timeout in favor of the default

2018-08-01 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565964#comment-16565964 ] Jason Gustafson commented on KAFKA-7231: Ouch. I think the only place we use this is in the

[jira] [Assigned] (KAFKA-7231) NetworkClient.newClientRequest() ignores custom request timeout in favor of the default

2018-08-01 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-7231: -- Assignee: Jason Gustafson > NetworkClient.newClientRequest() ignores custom request

[jira] [Updated] (KAFKA-7228) DeadLetterQueue throws a NullPointerException

2018-08-01 Thread Arjun Satish (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arjun Satish updated KAFKA-7228: Fix Version/s: 2.1.0 2.0.1 > DeadLetterQueue throws a NullPointerException >

[jira] [Updated] (KAFKA-7231) NetworkClient.newClientRequest() ignores custom request timeout in favor of the default

2018-08-01 Thread Ron Dagostino (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ron Dagostino updated KAFKA-7231: - Description: The below code in {{org.apache.kafka.clients.KafkaClient}} is not passing in the

[jira] [Created] (KAFKA-7231) NetworkClient.newClientRequest() ignores custom request timeout in favor of the default

2018-08-01 Thread Ron Dagostino (JIRA)
Ron Dagostino created KAFKA-7231: Summary: NetworkClient.newClientRequest() ignores custom request timeout in favor of the default Key: KAFKA-7231 URL: https://issues.apache.org/jira/browse/KAFKA-7231

[jira] [Commented] (KAFKA-7209) Kafka stream does not rebalance when one node gets down

2018-08-01 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565772#comment-16565772 ] Matthias J. Sax commented on KAFKA-7209: About `offsets.topic.replication.factor` – if you set it

[jira] [Commented] (KAFKA-6868) BufferUnderflowException in client when querying consumer group information

2018-08-01 Thread Sriharsha Chintalapani (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565753#comment-16565753 ] Sriharsha Chintalapani commented on KAFKA-6868: --- [~hachikuji] can we include this into 1.1

[jira] [Resolved] (KAFKA-7161) KTable Reduce should check for invalid conditions

2018-08-01 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-7161. -- Resolution: Fixed Fix Version/s: 2.1.0 > KTable Reduce should check for invalid

[jira] [Commented] (KAFKA-7161) KTable Reduce should check for invalid conditions

2018-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565731#comment-16565731 ] ASF GitHub Bot commented on KAFKA-7161: --- guozhangwang closed pull request #5366: KAFKA-7161: check

[jira] [Comment Edited] (KAFKA-7226) kafka-console-consumer.sh doesn't use security.protocol provided in config file

2018-08-01 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565681#comment-16565681 ] Manikumar edited comment on KAFKA-7226 at 8/1/18 5:37 PM: -- looks like the issue

[jira] [Commented] (KAFKA-7219) Add topic/partition level metrics.

2018-08-01 Thread George Teo (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565692#comment-16565692 ] George Teo commented on KAFKA-7219: --- Another slightly bigger ask would be to also emit Lowwatermark

[jira] [Updated] (KAFKA-7230) Empty Record created when producer fails due to RecordTooLargeException

2018-08-01 Thread Julien Fabre (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Julien Fabre updated KAFKA-7230: Summary: Empty Record created when producer fails due to RecordTooLargeException (was: Empty

[jira] [Updated] (KAFKA-7230) Empty Record created when producer failed due to RecordTooLargeException

2018-08-01 Thread Julien Fabre (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Julien Fabre updated KAFKA-7230: Description: When a producer tries to produce a RecordBatch which is bigger than the

[jira] [Updated] (KAFKA-7230) Empty Record created when producer failed due to RecordTooLargeException

2018-08-01 Thread Julien Fabre (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Julien Fabre updated KAFKA-7230: Description: When a producer tries to produce a RecordBatch (or Message) which is bigger than the

[jira] [Updated] (KAFKA-7230) Empty Record created when producer failed due to RecordTooLargeException

2018-08-01 Thread Julien Fabre (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Julien Fabre updated KAFKA-7230: Description: When a producer tries to produce a RecordBatch which is bigger than the

[jira] [Updated] (KAFKA-7230) Empty Record created when producer failed due to RecordTooLargeException

2018-08-01 Thread Julien Fabre (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Julien Fabre updated KAFKA-7230: Description: When a producer tries to produce a RecordBatch which is bigger than the

[jira] [Commented] (KAFKA-7226) kafka-console-consumer.sh doesn't use security.protocol provided in config file

2018-08-01 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565681#comment-16565681 ] Manikumar commented on KAFKA-7226: -- looks like the issue is specific to HDP Kafka distribution. Can you

[jira] [Updated] (KAFKA-7230) Empty Record created when producer failed due to RecordTooLargeException

2018-08-01 Thread Julien Fabre (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Julien Fabre updated KAFKA-7230: Description: When a producer tries to produce a RecordBatch which is bigger than the

[jira] [Created] (KAFKA-7230) Empty Record created when producer failed due to RecordTooLargeException

2018-08-01 Thread Julien Fabre (JIRA)
Julien Fabre created KAFKA-7230: --- Summary: Empty Record created when producer failed due to RecordTooLargeException Key: KAFKA-7230 URL: https://issues.apache.org/jira/browse/KAFKA-7230 Project: Kafka

[jira] [Commented] (KAFKA-7219) Add topic/partition level metrics.

2018-08-01 Thread Sriharsha Chintalapani (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565641#comment-16565641 ] Sriharsha Chintalapani commented on KAFKA-7219: --- [~satish.duggana] one more suggestion to

[jira] [Updated] (KAFKA-7229) Failed to dynamically update kafka certificate in kafka 2.0.0

2018-08-01 Thread Yu Yang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Yang updated KAFKA-7229: --- Priority: Major (was: Critical) > Failed to dynamically update kafka certificate in kafka 2.0.0 >

[jira] [Issue Comment Deleted] (KAFKA-7229) Failed to dynamically update kafka certificate in kafka 2.0.0

2018-08-01 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-7229: - Comment: was deleted (was: This may be due to the default value change for

[jira] [Commented] (KAFKA-7229) Failed to dynamically update kafka certificate in kafka 2.0.0

2018-08-01 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565625#comment-16565625 ] Manikumar commented on KAFKA-7229: -- This may be due to the default value change for

[jira] [Updated] (KAFKA-7144) Kafka Streams doesn't properly balance partition assignment

2018-08-01 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-7144: - Fix Version/s: 2.0.1 > Kafka Streams doesn't properly balance partition assignment >

[jira] [Commented] (KAFKA-7229) Failed to dynamically update kafka certificate in kafka 2.0.0

2018-08-01 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565613#comment-16565613 ] Ismael Juma commented on KAFKA-7229: Looks like you have to disable hostname verification, which is

[jira] [Updated] (KAFKA-7229) Failed to dynamically update kafka certificate in kafka 2.0.0

2018-08-01 Thread Yu Yang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Yang updated KAFKA-7229: --- Priority: Critical (was: Major) > Failed to dynamically update kafka certificate in kafka 2.0.0 >

[jira] [Updated] (KAFKA-7229) Failed to dynamically update kafka certificate in kafka 2.0.0

2018-08-01 Thread Yu Yang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Yang updated KAFKA-7229: --- Description: In kafka 1.1, we use the following command in a cron job to dynamically update the certificate

[jira] [Commented] (KAFKA-7228) DeadLetterQueue throws a NullPointerException

2018-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565540#comment-16565540 ] ASF GitHub Bot commented on KAFKA-7228: --- wicknicks opened a new pull request #5440: KAFKA-7228: Set

[jira] [Updated] (KAFKA-7228) DeadLetterQueue throws a NullPointerException

2018-08-01 Thread Arjun Satish (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arjun Satish updated KAFKA-7228: Description: Using the dead letter queue results in a NPE:  {code:java} [2018-08-01 07:41:08,907]

[jira] [Created] (KAFKA-7228) DeadLetterQueue throws a NullPointerException

2018-08-01 Thread Arjun Satish (JIRA)
Arjun Satish created KAFKA-7228: --- Summary: DeadLetterQueue throws a NullPointerException Key: KAFKA-7228 URL: https://issues.apache.org/jira/browse/KAFKA-7228 Project: Kafka Issue Type: Task

[jira] [Assigned] (KAFKA-7228) DeadLetterQueue throws a NullPointerException

2018-08-01 Thread Arjun Satish (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arjun Satish reassigned KAFKA-7228: --- Assignee: Arjun Satish > DeadLetterQueue throws a NullPointerException >

[jira] [Commented] (KAFKA-7215) Improve LogCleaner behavior on error

2018-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565498#comment-16565498 ] ASF GitHub Bot commented on KAFKA-7215: --- stanislavkozlovski opened a new pull request #5439:

[jira] [Updated] (KAFKA-5587) Processor got uncaught exception: NullPointerException

2018-08-01 Thread lambdaliu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lambdaliu updated KAFKA-5587: - Affects Version/s: 0.10.2.1 > Processor got uncaught exception: NullPointerException >

[jira] [Updated] (KAFKA-7227) Kafka cluster should has a default rack id if not set

2018-08-01 Thread Genmao Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Genmao Yu updated KAFKA-7227: - Priority: Minor (was: Major) > Kafka cluster should has a default rack id if not set >

[jira] [Updated] (KAFKA-7227) Kafka cluster should has a default rack id if not set

2018-08-01 Thread Genmao Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Genmao Yu updated KAFKA-7227: - Description: In current behavior, if partial of broker machines have "server.rack",  we will failed to

[jira] [Commented] (KAFKA-7216) Exception while running kafka-acls.sh from 1.0 env on target Kafka env with 1.1.1

2018-08-01 Thread Satish Duggana (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565242#comment-16565242 ] Satish Duggana commented on KAFKA-7216: --- [~ijuma] I set component as `admin` as `AclCommand` is one

[jira] [Updated] (KAFKA-7227) Kafka cluster should has a default rack id if not set

2018-08-01 Thread Genmao Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Genmao Yu updated KAFKA-7227: - Description: In current behavior, if partial of broker machines have "server.rack",  we will failed to

[jira] [Created] (KAFKA-7227) Kafka cluster should has a default rack id if not set

2018-08-01 Thread Genmao Yu (JIRA)
Genmao Yu created KAFKA-7227: Summary: Kafka cluster should has a default rack id if not set Key: KAFKA-7227 URL: https://issues.apache.org/jira/browse/KAFKA-7227 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-7226) kafka-console-consumer.sh doesn't use security.protocol provided in config file

2018-08-01 Thread Alexandre GRIFFAUT (JIRA)
Alexandre GRIFFAUT created KAFKA-7226: - Summary: kafka-console-consumer.sh doesn't use security.protocol provided in config file Key: KAFKA-7226 URL: https://issues.apache.org/jira/browse/KAFKA-7226

[jira] [Updated] (KAFKA-5928) Avoid redundant requests to zookeeper when reassign topic partition

2018-08-01 Thread Genmao Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Genmao Yu updated KAFKA-5928: - Affects Version/s: 2.0.0 > Avoid redundant requests to zookeeper when reassign topic partition >

[jira] [Updated] (KAFKA-5928) Avoid redundant requests to zookeeper when reassign topic partition

2018-08-01 Thread Genmao Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Genmao Yu updated KAFKA-5928: - Affects Version/s: 1.0.0 > Avoid redundant requests to zookeeper when reassign topic partition >

[jira] [Updated] (KAFKA-7225) Kafka Connect ConfigProvider not invoked before validation

2018-08-01 Thread Nacho Munoz (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nacho Munoz updated KAFKA-7225: --- Description: When trying to register a JDBC connector with externalised secrets (e.g.

[jira] [Created] (KAFKA-7225) Kafka Connect ConfigProvider not invoked before validation

2018-08-01 Thread Nacho Munoz (JIRA)
Nacho Munoz created KAFKA-7225: -- Summary: Kafka Connect ConfigProvider not invoked before validation Key: KAFKA-7225 URL: https://issues.apache.org/jira/browse/KAFKA-7225 Project: Kafka Issue

[jira] [Commented] (KAFKA-6188) Broker fails with FATAL Shutdown - log dirs have failed

2018-08-01 Thread Peng Peng (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565055#comment-16565055 ] Peng Peng commented on KAFKA-6188: -- [~ijuma] I also met this issue when restart Kafka Server, Is there

[jira] [Commented] (KAFKA-7165) Error while creating ephemeral at /brokers/ids/BROKER_ID

2018-08-01 Thread Jonathan Santilli (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16564932#comment-16564932 ] Jonathan Santilli commented on KAFKA-7165: -- Sure [~omkreddy] , it makes sense, some

[jira] [Commented] (KAFKA-3821) Allow Kafka Connect source tasks to produce offset without writing to topics

2018-08-01 Thread Gunnar Morling (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16564900#comment-16564900 ] Gunnar Morling commented on KAFKA-3821: --- One other alternative came to my mind which avoids

[jira] [Commented] (KAFKA-6963) KIP-310: Add a Kafka Source Connector to Kafka Connect

2018-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16564863#comment-16564863 ] ASF GitHub Bot commented on KAFKA-6963: --- rhysmccaig opened a new pull request #5438: KAFKA-6963:

[jira] [Commented] (KAFKA-6690) Priorities for Source Topics

2018-08-01 Thread Bala Prassanna I (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16564809#comment-16564809 ] Bala Prassanna I commented on KAFKA-6690: - [~nafshartous] I am okay with the KIP > Priorities