[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=16688060#comment-16688060 ] Kobi Hikri commented on KAFKA-1194: --- [~stephane.maa...@gmail.com], Thanks. Doing it now and will

[jira] [Created] (KAFKA-7632) Add option to kafka broker config to adjust compression level for zstd

Dave Waters created KAFKA-7632: -- Summary: Add option to kafka broker config to adjust compression level for zstd Key: KAFKA-7632 URL: https://issues.apache.org/jira/browse/KAFKA-7632 Project: Kafka

[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=16688044#comment-16688044 ] Stephane Maarek commented on KAFKA-1194: [~Kobi Hikri] excellent, I'll be happy to help out and

[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=16688174#comment-16688174 ] Kobi Hikri commented on KAFKA-1194: --- [~stephane.maa...@gmail.com], I was too quick to draw. The fix

[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=16688177#comment-16688177 ] Kobi Hikri commented on KAFKA-1194: --- Absolutely! > The kafka broker cannot delete the old log files

[jira] [Comment Edited] (KAFKA-7610) Detect consumer failures in initial JoinGroup

[ https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688332#comment-16688332 ] Boyang Chen edited comment on KAFKA-7610 at 11/15/18 4:44 PM: -- Hey

[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

[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=16688085#comment-16688085 ] Kobi Hikri commented on KAFKA-1194: --- [~stephane.maa...@gmail.com], here it is:

[jira] [Comment Edited] (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=16688085#comment-16688085 ] Kobi Hikri edited comment on KAFKA-1194 at 11/15/18 1:48 PM: -

[jira] [Commented] (KAFKA-7608) A Kafka Streams DSL transform or process call should potentially trigger a repartition

[ https://issues.apache.org/jira/browse/KAFKA-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688333#comment-16688333 ] Bill Bejeck commented on KAFKA-7608: Hi Andy, The fact that transform, transformValues, and process

[jira] [Commented] (KAFKA-7584) StreamsConfig throws ClassCastException if max.in.flight.request.per.connect is specified as String

[ https://issues.apache.org/jira/browse/KAFKA-7584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688677#comment-16688677 ] ASF GitHub Bot commented on KAFKA-7584: --- guozhangwang closed pull request #5874: KAFKA-7584:

[jira] [Updated] (KAFKA-7633) Kafka Connect requires permission to create internal topics even if they exist

[ https://issues.apache.org/jira/browse/KAFKA-7633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arabelle Hou updated KAFKA-7633: Description: Similar to issue https://issues.apache.org/jira/browse/KAFKA-6250 but now with a

[jira] [Updated] (KAFKA-7633) Kafka Connect requires permission to create internal topics even if they exist

[ https://issues.apache.org/jira/browse/KAFKA-7633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arabelle Hou updated KAFKA-7633: Description: Similar to issue https://issues.apache.org/jira/browse/KAFKA-6250 but now with a

[jira] [Updated] (KAFKA-7584) StreamsConfig throws ClassCastException if max.in.flight.request.per.connect is specified as String

[ https://issues.apache.org/jira/browse/KAFKA-7584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-7584: - Fix Version/s: 2.2.0 > StreamsConfig throws ClassCastException if

[jira] [Updated] (KAFKA-7633) Kafka Connect requires permission to create internal topics even if they exist

[ https://issues.apache.org/jira/browse/KAFKA-7633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arabelle Hou updated KAFKA-7633: Description: Similar to issue https://issues.apache.org/jira/browse/KAFKA-6250 but now with a

[jira] [Created] (KAFKA-7633) Kafka Connect requires permission to create internal topics even if they exist

Arabelle Hou created KAFKA-7633: --- Summary: Kafka Connect requires permission to create internal topics even if they exist Key: KAFKA-7633 URL: https://issues.apache.org/jira/browse/KAFKA-7633 Project:

[jira] [Commented] (KAFKA-7633) Kafka Connect requires permission to create internal topics even if they exist

[ https://issues.apache.org/jira/browse/KAFKA-7633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688737#comment-16688737 ] ASF GitHub Bot commented on KAFKA-7633: --- arabelle opened a new pull request #5918: KAFKA-7633:

[jira] [Commented] (KAFKA-7608) A Kafka Streams DSL transform or process call should potentially trigger a repartition

[ https://issues.apache.org/jira/browse/KAFKA-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688729#comment-16688729 ] Andy Bryant commented on KAFKA-7608: Hi Bill That sounds like a better solution. I see your point

[jira] [Commented] (KAFKA-7443) OffsetOutOfRangeException in restoring state store from changelog topic when start offset of local checkpoint is smaller than that of changelog topic

[ https://issues.apache.org/jira/browse/KAFKA-7443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688798#comment-16688798 ] John Roesler commented on KAFKA-7443: - Hi [~linyli], Wow, this seems like a pretty bad condition.

[jira] [Commented] (KAFKA-7595) Kafka Streams: KTrable to KTable join introduces duplicates in downstream KTable

[ https://issues.apache.org/jira/browse/KAFKA-7595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688927#comment-16688927 ] Vik Gamov commented on KAFKA-7595: -- [~mjsax] [~vvcephei]  Thank you for input. I was able to rewrite my

[jira] [Commented] (KAFKA-7576) Dynamic update of replica fetcher threads may fail to start/close fetchers

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

[jira] [Commented] (KAFKA-7192) State-store can desynchronise with changelog

[ https://issues.apache.org/jira/browse/KAFKA-7192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689059#comment-16689059 ] ASF GitHub Bot commented on KAFKA-7192: --- guozhangwang closed pull request #5915: KAFKA-7192: Wipe

[jira] [Created] (KAFKA-7634) Punctuate not being called with merge() and/or outerJoin()

Eugen Feller created KAFKA-7634: --- Summary: Punctuate not being called with merge() and/or outerJoin() Key: KAFKA-7634 URL: https://issues.apache.org/jira/browse/KAFKA-7634 Project: Kafka Issue

[jira] [Commented] (KAFKA-7628) KafkaStream is not closing

[ https://issues.apache.org/jira/browse/KAFKA-7628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689085#comment-16689085 ] Ozgur commented on KAFKA-7628: -- Hi Guozhang, I've upgraded my client version to the last version (2.0.1)

[jira] [Resolved] (KAFKA-7628) KafkaStream is not closing

[ https://issues.apache.org/jira/browse/KAFKA-7628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ozgur resolved KAFKA-7628. -- Resolution: Fixed This issue caused by the another component of the application. Processor implementation

[jira] [Commented] (KAFKA-7628) KafkaStream is not closing

[ https://issues.apache.org/jira/browse/KAFKA-7628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689078#comment-16689078 ] Guozhang Wang commented on KAFKA-7628: -- In old versions of Kafka Streams there may be some bugs

[jira] [Commented] (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:comment-tabpanel=16687631#comment-16687631 ] Andras Beni commented on KAFKA-7631: [~asasvari], [~viktorsomogyi] you might want to look at this

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

Andras Beni created KAFKA-7631: -- Summary: NullPointerException when SCRAM is allowed bu ScramLoginModule is not in broker's jaas.conf Key: KAFKA-7631 URL: https://issues.apache.org/jira/browse/KAFKA-7631

[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=16687874#comment-16687874 ] Kobi Hikri commented on KAFKA-1194: --- Hi guys, Anyone from the core team, who want to help me in

[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=16687984#comment-16687984 ] Harald Kirsch commented on KAFKA-1194: -- [~Kobi Hikri] please be sure to understand the likely

[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=16688007#comment-16688007 ] Harald Kirsch commented on KAFKA-1194: -- [~Kobi Hikri] Good you know about! :) But I am not in a

[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=16688008#comment-16688008 ] M. Manna commented on KAFKA-1194: - Just out of curiosity, have you considered dockerising your Kafka

[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=16687995#comment-16687995 ] Kobi Hikri commented on KAFKA-1194: --- Thanks [~haraldk], I actually do understand the principle here :).