[jira] [Commented] (KAFKA-6851) Kafka CLI commands should support specifying the servers in environment variables

[ https://issues.apache.org/jira/browse/KAFKA-6851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16461838#comment-16461838 ] Brett Rann commented on KAFKA-6851: --- I personally wouldn't call the solutions people gav

[jira] [Commented] (KAFKA-4041) kafka unable to reconnect to zookeeper behind an ELB

[ https://issues.apache.org/jira/browse/KAFKA-4041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16461830#comment-16461830 ] David Glasser commented on KAFKA-4041: -- I think this should be reopened, because I th

[jira] [Commented] (KAFKA-5473) handle ZK session expiration properly when a new session can't be established

[ https://issues.apache.org/jira/browse/KAFKA-5473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16461823#comment-16461823 ] David Glasser commented on KAFKA-5473: -- KAFKA-4041 claims that this fix, which is in

[jira] [Commented] (KAFKA-6829) Consumer should retry when encountering unknown topic or partition error

[ https://issues.apache.org/jira/browse/KAFKA-6829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16461754#comment-16461754 ] ASF GitHub Bot commented on KAFKA-6829: --- guozhangwang closed pull request #4948: KAF

[jira] [Commented] (KAFKA-6840) support windowing in ktable API

[ https://issues.apache.org/jira/browse/KAFKA-6840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16461659#comment-16461659 ] Boyang Chen commented on KAFKA-6840: Sounds good, I will give it a try [~mjsax] > sup

[jira] [Resolved] (KAFKA-6657) Add StreamsConfig prefix for different consumers

[ https://issues.apache.org/jira/browse/KAFKA-6657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-6657. Resolution: Delivered The code is merged: https://github.com/apache/kafka/pull/4805 > Add StreamsCo

[jira] [Commented] (KAFKA-6846) Controller can spend long time in shutting down RequestSendThread when processing BrokerChange event

[ https://issues.apache.org/jira/browse/KAFKA-6846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16461649#comment-16461649 ] ASF GitHub Bot commented on KAFKA-6846: --- hzxa21 opened a new pull request #4960: KAF

[jira] [Commented] (KAFKA-6657) Add StreamsConfig prefix for different consumers

[ https://issues.apache.org/jira/browse/KAFKA-6657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16461585#comment-16461585 ] ASF GitHub Bot commented on KAFKA-6657: --- guozhangwang closed pull request #4805: KAF

[jira] [Updated] (KAFKA-6786) Remove additional configs in StreamsBrokerDownResilienceTest

[ https://issues.apache.org/jira/browse/KAFKA-6786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6786: - Description: Since we are now passing in a property file into the streams service initialization c

[jira] [Updated] (KAFKA-6786) Remove additional configs in StreamsBrokerDownResilienceTest

[ https://issues.apache.org/jira/browse/KAFKA-6786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6786: - Summary: Remove additional configs in StreamsBrokerDownResilienceTest (was: Remove additional con

[jira] [Comment Edited] (KAFKA-6786) Remove additional configs in StreamsStandbyTask

[ https://issues.apache.org/jira/browse/KAFKA-6786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16461557#comment-16461557 ] Guozhang Wang edited comment on KAFKA-6786 at 5/2/18 7:59 PM: --

[jira] [Commented] (KAFKA-6786) Remove additional configs in StreamsStandbyTask

[ https://issues.apache.org/jira/browse/KAFKA-6786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16461557#comment-16461557 ] Guozhang Wang commented on KAFKA-6786: -- Jimin, Yes that's right. Thanks for pointing

[jira] [Commented] (KAFKA-6849) Add transformValues() method to KTable

[ https://issues.apache.org/jira/browse/KAFKA-6849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16461545#comment-16461545 ] ASF GitHub Bot commented on KAFKA-6849: --- big-andy-coates opened a new pull request #

[jira] [Commented] (KAFKA-6825) DEFAULT_PRODUCTION_EXCEPTION_HANDLER_CLASS_CONFIG is private

[ https://issues.apache.org/jira/browse/KAFKA-6825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16461495#comment-16461495 ] ASF GitHub Bot commented on KAFKA-6825: --- guozhangwang closed pull request #4929: KAF

[jira] [Commented] (KAFKA-6843) Document issue with DNS TTL

[ https://issues.apache.org/jira/browse/KAFKA-6843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16461448#comment-16461448 ] David Glasser commented on KAFKA-6843: -- Sorry, I may be wrong here. I think the defau

[jira] [Updated] (KAFKA-6850) KIP-244: Add Record Header support to Kafka Streams Processor API

[ https://issues.apache.org/jira/browse/KAFKA-6850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6850: --- Labels: kip (was: ) > KIP-244: Add Record Header support to Kafka Streams Processor API > ---

[jira] [Updated] (KAFKA-6849) Add transformValues() method to KTable

[ https://issues.apache.org/jira/browse/KAFKA-6849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6849: --- Labels: kip (was: ) > Add transformValues() method to KTable > -

[jira] [Commented] (KAFKA-6835) Enable topic unclean leader election to be enabled without controller change

[ https://issues.apache.org/jira/browse/KAFKA-6835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16461114#comment-16461114 ] ASF GitHub Bot commented on KAFKA-6835: --- omkreddy opened a new pull request #4957: K

[jira] [Created] (KAFKA-6852) Allow Log Levels to be dynamically configured

Yeva Byzek created KAFKA-6852: - Summary: Allow Log Levels to be dynamically configured Key: KAFKA-6852 URL: https://issues.apache.org/jira/browse/KAFKA-6852 Project: Kafka Issue Type: Improvement

[jira] [Updated] (KAFKA-6851) Kafka CLI commands should support specifying the servers in environment variables

[ https://issues.apache.org/jira/browse/KAFKA-6851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peter Horvath updated KAFKA-6851: - Issue Type: Improvement (was: New Feature) > Kafka CLI commands should support specifying the ser

[jira] [Created] (KAFKA-6851) Kafka CLI commands should support specifying the servers in environment variables

Peter Horvath created KAFKA-6851: Summary: Kafka CLI commands should support specifying the servers in environment variables Key: KAFKA-6851 URL: https://issues.apache.org/jira/browse/KAFKA-6851 Proje

[jira] [Commented] (KAFKA-3665) Default ssl.endpoint.identification.algorithm should be https

[ https://issues.apache.org/jira/browse/KAFKA-3665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16461049#comment-16461049 ] ASF GitHub Bot commented on KAFKA-3665: --- rajinisivaram opened a new pull request #49

[jira] [Created] (KAFKA-6850) KIP-244: Add Record Header support to Kafka Streams Processor API

Jorge Quilcate created KAFKA-6850: - Summary: KIP-244: Add Record Header support to Kafka Streams Processor API Key: KAFKA-6850 URL: https://issues.apache.org/jira/browse/KAFKA-6850 Project: Kafka

[jira] [Created] (KAFKA-6849) Add transformValues() method to KTable

Andy Coates created KAFKA-6849: -- Summary: Add transformValues() method to KTable Key: KAFKA-6849 URL: https://issues.apache.org/jira/browse/KAFKA-6849 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-6848) Kafka consumer failed to get correct offset after commit

YY.Roy created KAFKA-6848: - Summary: Kafka consumer failed to get correct offset after commit Key: KAFKA-6848 URL: https://issues.apache.org/jira/browse/KAFKA-6848 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-6847) PeriodicProducerExpirationCheck

Sunil Kumar created KAFKA-6847: -- Summary: PeriodicProducerExpirationCheck Key: KAFKA-6847 URL: https://issues.apache.org/jira/browse/KAFKA-6847 Project: Kafka Issue Type: Bug Reporte

[jira] [Updated] (KAFKA-6840) support windowing in ktable API

[ https://issues.apache.org/jira/browse/KAFKA-6840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6840: --- Labels: api needs-kip (was: api) > support windowing in ktable API >

[jira] [Commented] (KAFKA-6840) support windowing in ktable API

[ https://issues.apache.org/jira/browse/KAFKA-6840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16460783#comment-16460783 ] Matthias J. Sax commented on KAFKA-6840: Thanks for the ticket. I am wondering, if

[jira] [Commented] (KAFKA-6834) log cleaner should handle the case when the size of a message set is larger than the max message size

[ https://issues.apache.org/jira/browse/KAFKA-6834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16460689#comment-16460689 ] ASF GitHub Bot commented on KAFKA-6834: --- rajinisivaram opened a new pull request #49

[jira] [Created] (KAFKA-6846) Controller can spend long time in shutting down RequestSendThread when processing BrokerChange event

Zhanxiang Huang created KAFKA-6846: -- Summary: Controller can spend long time in shutting down RequestSendThread when processing BrokerChange event Key: KAFKA-6846 URL: https://issues.apache.org/jira/browse/KAFKA-