[jira] [Resolved] (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 ] Manikumar resolved KAFKA-7752. -- Resolution: Fixed Fix Version/s: 2.2.0 Issue resolved by pull request 6072 [https://github.com/a

[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=16734022#comment-16734022 ] ASF GitHub Bot commented on KAFKA-7752: --- omkreddy commented on pull request #6072:

[jira] [Commented] (KAFKA-7510) KStreams RecordCollectorImpl leaks data to logs on error

[ https://issues.apache.org/jira/browse/KAFKA-7510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16734079#comment-16734079 ] ASF GitHub Bot commented on KAFKA-7510: --- mjsax commented on pull request #5834: ref

[jira] [Commented] (KAFKA-7580) Unit Test 'shouldThrowProcessorStateExceptionOnOpeningReadOnlyDir' fails when run as root user

[ https://issues.apache.org/jira/browse/KAFKA-7580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16734084#comment-16734084 ] Matthias J. Sax commented on KAFKA-7580: Should we close this as "won't fix" > U

[jira] [Commented] (KAFKA-7688) Allow byte array class for Decimal Logical Types to fix Debezium Issues

[ https://issues.apache.org/jira/browse/KAFKA-7688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16734106#comment-16734106 ] Manjeet Duhan commented on KAFKA-7688: -- Is there any update on this issue ? I am als

[jira] [Commented] (KAFKA-7780) Kafka client should validate topic-level configs and update only unique values

[ https://issues.apache.org/jira/browse/KAFKA-7780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16734121#comment-16734121 ] ASF GitHub Bot commented on KAFKA-7780: --- ManoharVanam commented on pull request #60

[jira] [Resolved] (KAFKA-7580) Unit Test 'shouldThrowProcessorStateExceptionOnOpeningReadOnlyDir' fails when run as root user

[ https://issues.apache.org/jira/browse/KAFKA-7580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sarvesh Tamba resolved KAFKA-7580. -- Resolution: Won't Fix Refer PR [https://github.com/apache/kafka/pull/6020] for more details on

[jira] [Commented] (KAFKA-7580) Unit Test 'shouldThrowProcessorStateExceptionOnOpeningReadOnlyDir' fails when run as root user

[ https://issues.apache.org/jira/browse/KAFKA-7580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16734152#comment-16734152 ] Sarvesh Tamba commented on KAFKA-7580: -- [~mjsax] done. Thanks for all your help. >

[jira] [Comment Edited] (KAFKA-7743) "pure virtual method called" error message thrown for unit tests which PASS

[ https://issues.apache.org/jira/browse/KAFKA-7743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16733850#comment-16733850 ] Sarvesh Tamba edited comment on KAFKA-7743 at 1/4/19 2:00 PM: -

[jira] [Updated] (KAFKA-7757) Too many open files after java.io.IOException: Connection to n was disconnected before the response was read

[ https://issues.apache.org/jira/browse/KAFKA-7757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Nadler updated KAFKA-7757: --- Attachment: Screen Shot 2019-01-03 at 12.20.38 PM.png > Too many open files after java.io.IOException

[jira] [Commented] (KAFKA-7757) Too many open files after java.io.IOException: Connection to n was disconnected before the response was read

[ https://issues.apache.org/jira/browse/KAFKA-7757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16734308#comment-16734308 ] Jeff Nadler commented on KAFKA-7757: This happens to us as well after 2.0 -> 2.1.0 up

[jira] [Commented] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16734415#comment-16734415 ] Boyang Chen commented on KAFKA-7672: [~guozhang] Are you suggesting sth similar to th

[jira] [Commented] (KAFKA-7743) "pure virtual method called" error message thrown for unit tests which PASS

[ https://issues.apache.org/jira/browse/KAFKA-7743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16734459#comment-16734459 ] Guozhang Wang commented on KAFKA-7743: -- You can read README.md: {code} ### Common b

[jira] [Commented] (KAFKA-6928) StreamsPartitionAssignor is double retrying within InternalTopicManager

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

[jira] [Resolved] (KAFKA-6928) StreamsPartitionAssignor is double retrying within InternalTopicManager

[ https://issues.apache.org/jira/browse/KAFKA-6928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6928. -- Resolution: Fixed Fix Version/s: 2.1.1 2.2.0 > StreamsPartitionAssign

[jira] [Commented] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16734491#comment-16734491 ] Guozhang Wang commented on KAFKA-7672: -- [~bchen225242] are you referring to the fix

[jira] [Commented] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16734504#comment-16734504 ] Boyang Chen commented on KAFKA-7672: [~guozhang] Yes the second issue. So since `atom

[jira] [Resolved] (KAFKA-4835) Allow users control over repartitioning

[ https://issues.apache.org/jira/browse/KAFKA-4835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-4835. Resolution: Fixed > Allow users control over repartitioning > -

[jira] [Commented] (KAFKA-7110) Windowed changelog keys not deserialized properly by TimeWindowedSerde

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

[jira] [Assigned] (KAFKA-7786) Fast update of leader epoch may stall partition fetching due to FENCED_LEADER_EPOCH

[ https://issues.apache.org/jira/browse/KAFKA-7786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anna Povzner reassigned KAFKA-7786: --- Assignee: Anna Povzner > Fast update of leader epoch may stall partition fetching due to >

[jira] [Commented] (KAFKA-7657) Invalid reporting of stream state in Kafka streams application

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

[jira] [Commented] (KAFKA-7657) Invalid reporting of stream state in Kafka streams application

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

[jira] [Commented] (KAFKA-7657) Invalid reporting of stream state in Kafka streams application

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

[jira] [Updated] (KAFKA-7772) Dynamically adjust log level in Connect workers

[ https://issues.apache.org/jira/browse/KAFKA-7772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-7772: - Labels: needs-kip (was: ) > Dynamically adjust log level in Connect workers > --

[jira] [Created] (KAFKA-7787) Add error specifications to KAFKA-7609

Colin P. McCabe created KAFKA-7787: -- Summary: Add error specifications to KAFKA-7609 Key: KAFKA-7787 URL: https://issues.apache.org/jira/browse/KAFKA-7787 Project: Kafka Issue Type: Improvem

[jira] [Created] (KAFKA-7788) Support null defaults in KAFKA-7609 RPC specifications

Colin P. McCabe created KAFKA-7788: -- Summary: Support null defaults in KAFKA-7609 RPC specifications Key: KAFKA-7788 URL: https://issues.apache.org/jira/browse/KAFKA-7788 Project: Kafka Issu

[jira] [Resolved] (KAFKA-7657) Invalid reporting of stream state in Kafka streams application

[ https://issues.apache.org/jira/browse/KAFKA-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-7657. -- Resolution: Fixed Assignee: Guozhang Wang Fix Version/s: 2.2.0 > Invalid report

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

[ https://issues.apache.org/jira/browse/KAFKA-7181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16734776#comment-16734776 ] Guozhang Wang commented on KAFKA-7181: -- Resolving this issue as the same fix for 765

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

[ https://issues.apache.org/jira/browse/KAFKA-7181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-7181. -- Resolution: Fixed Fix Version/s: 2.2.0 > Kafka Streams State stuck in rebalancing after