[jira] [Commented] (KAFKA-6831) FileStreamSink is very slow

[ https://issues.apache.org/jira/browse/KAFKA-6831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16459466#comment-16459466 ] Prabhat Verma commented on KAFKA-6831: -- Any help please ... > FileStreamSink is very slow >

[jira] [Commented] (KAFKA-6774) Improve default groupId behavior in consumer

[ https://issues.apache.org/jira/browse/KAFKA-6774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16459266#comment-16459266 ] Jason Gustafson commented on KAFKA-6774: [~vahid] The suggestion here would be to have the

[jira] [Commented] (KAFKA-6390) Update ZooKeeper to 3.4.11, Gradle and other minor updates

[ https://issues.apache.org/jira/browse/KAFKA-6390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16459102#comment-16459102 ] Jennifer Thompson commented on KAFKA-6390: -- That issue (ZOOKEEPER-2960) should be fixed in 3.4.12

[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 ] Boyang Chen updated KAFKA-6840: --- Labels: api (was: ) > support windowing in ktable API > --- > >

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

Boyang Chen created KAFKA-6840: -- Summary: support windowing in ktable API Key: KAFKA-6840 URL: https://issues.apache.org/jira/browse/KAFKA-6840 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (KAFKA-6810) Enable dynamic reconfiguration of SSL truststores

[ https://issues.apache.org/jira/browse/KAFKA-6810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6810. Resolution: Fixed > Enable dynamic reconfiguration of SSL truststores >

[jira] [Updated] (KAFKA-6839) ZK session retry with cname record

[ https://issues.apache.org/jira/browse/KAFKA-6839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tyler Monahan updated KAFKA-6839: - Description: I have a 3 node kafka cluster setup in aws that talks to a 3 node zk cluster behind

[jira] [Created] (KAFKA-6839) ZK session retry with cname record

Tyler Monahan created KAFKA-6839: Summary: ZK session retry with cname record Key: KAFKA-6839 URL: https://issues.apache.org/jira/browse/KAFKA-6839 Project: Kafka Issue Type: Bug Affects

[jira] [Commented] (KAFKA-6810) Enable dynamic reconfiguration of SSL truststores

[ https://issues.apache.org/jira/browse/KAFKA-6810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16458982#comment-16458982 ] ASF GitHub Bot commented on KAFKA-6810: --- hachikuji closed pull request #4904: KAFKA-6810: Enable

[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=16458810#comment-16458810 ] Colin P. McCabe commented on KAFKA-6834: Good catch! Maybe we should validate the CRC of the

[jira] [Commented] (KAFKA-3702) SslTransportLayer.close() does not shutdown gracefully

[ https://issues.apache.org/jira/browse/KAFKA-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16458786#comment-16458786 ] Xin Jin commented on KAFKA-3702: I also got this issue. The frequent log is annoying. >

[jira] [Assigned] (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:all-tabpanel ] Rajini Sivaram reassigned KAFKA-6834: - Assignee: Rajini Sivaram > log cleaner should handle the case when the size of a message

[jira] [Comment Edited] (KAFKA-3410) Unclean leader election and "Halting because log truncation is not allowed"

[ https://issues.apache.org/jira/browse/KAFKA-3410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16458652#comment-16458652 ] Ashish edited comment on KAFKA-3410 at 4/30/18 4:29 PM: We had a similar issue

[jira] [Commented] (KAFKA-3410) Unclean leader election and "Halting because log truncation is not allowed"

[ https://issues.apache.org/jira/browse/KAFKA-3410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16458652#comment-16458652 ] Ashish commented on KAFKA-3410: --- We had a similar issue with 0.10.2.1 version . Is there a fix for this

[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=16458625#comment-16458625 ] ASF GitHub Bot commented on KAFKA-6829: --- bbejeck opened a new pull request #4948: KAFKA-6829: Retry

[jira] [Commented] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time

[ https://issues.apache.org/jira/browse/KAFKA-1194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16458582#comment-16458582 ] ASF GitHub Bot commented on KAFKA-1194: --- mmanna-sapfgl opened a new pull request #4947: KAFKA-1194

[jira] [Commented] (KAFKA-6684) Support casting values with bytes schema to string

[ https://issues.apache.org/jira/browse/KAFKA-6684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16458568#comment-16458568 ] Amit Sela commented on KAFKA-6684: -- For Connect, it looks like supported logical types have

[jira] [Commented] (KAFKA-4133) Provide a configuration to control consumer max in-flight fetches

[ https://issues.apache.org/jira/browse/KAFKA-4133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16458528#comment-16458528 ] Mickael Maison commented on KAFKA-4133: --- Open a new PR: https://github.com/apache/kafka/pull/4934 >

[jira] [Commented] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time

[ https://issues.apache.org/jira/browse/KAFKA-1194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16458526#comment-16458526 ] M. Manna commented on KAFKA-1194: - I will adding a patch to the trunk and raise a PR. In the past I have

[jira] [Commented] (KAFKA-3417) Invalid characters in config properties not being validated?

[ https://issues.apache.org/jira/browse/KAFKA-3417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16458497#comment-16458497 ] ASF GitHub Bot commented on KAFKA-3417: --- rajinisivaram closed pull request #3635: KAFKA-3417: Wrap

[jira] [Commented] (KAFKA-6535) Set default retention ms for Streams repartition topics to Long.MAX_VALUE

[ https://issues.apache.org/jira/browse/KAFKA-6535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16458456#comment-16458456 ] ASF GitHub Bot commented on KAFKA-6535: --- mjsax closed pull request #4730: KAFKA-6535: Set default

[jira] [Created] (KAFKA-6838) Transaction timeout after punctuation results in ProducerFencedException

Felix Dsouza created KAFKA-6838: --- Summary: Transaction timeout after punctuation results in ProducerFencedException Key: KAFKA-6838 URL: https://issues.apache.org/jira/browse/KAFKA-6838 Project: Kafka

[jira] [Created] (KAFKA-6837) Apache kafka broker got stopped.

Rajendra Jangir created KAFKA-6837: -- Summary: Apache kafka broker got stopped. Key: KAFKA-6837 URL: https://issues.apache.org/jira/browse/KAFKA-6837 Project: Kafka Issue Type: Bug