[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 comm

[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&focusedCommentId=16689085#comment-16689085 ] Ozgur commented on KAFKA-7628: -- Hi Guozhang, I've upgraded my client version to the last ve

[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&focusedCommentId=16689078#comment-16689078 ] Guozhang Wang commented on KAFKA-7628: -- In old versions of Kafka Streams there may b

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

[ https://issues.apache.org/jira/browse/KAFKA-7634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16689061#comment-16689061 ] Guozhang Wang commented on KAFKA-7634: -- Hi [~efeller] could you try to upgrade to ne

[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&focusedCommentId=16689059#comment-16689059 ] ASF GitHub Bot commented on KAFKA-7192: --- guozhangwang closed pull request #5915: KA

[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&focusedCommentId=16688927#comment-16688927 ] Vik Gamov commented on KAFKA-7595: -- [~mjsax] [~vvcephei]  Thank you for input. I was ab

[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-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&focusedCommentId=1666#comment-1666 ] ASF GitHub Bot commented on KAFKA-7576: --- hachikuji closed pull request #5875: KAFKA

[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&focusedCommentId=16688798#comment-16688798 ] John Roesler commented on KAFKA-7443: - Hi [~linyli], Wow, this seems like a pretty b

[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 max.in.flight.request.per.conne

[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 diff

[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 diff

[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 diff

[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&focusedCommentId=16688737#comment-16688737 ] ASF GitHub Bot commented on KAFKA-7633: --- arabelle opened a new pull request #5918:

[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&focusedCommentId=16688729#comment-16688729 ] Andy Bryant commented on KAFKA-7608: Hi Bill That sounds like a better solution. I s

[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: K

[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&focusedCommentId=16688677#comment-16688677 ] ASF GitHub Bot commented on KAFKA-7584: --- guozhangwang closed pull request #5874: KA

[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&focusedCommentId=16688332#comment-16688332 ] Boyang Chen edited comment on KAFKA-7610 at 11/15/18 4:44 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&focusedCommentId=16688333#comment-16688333 ] Bill Bejeck commented on KAFKA-7608: Hi Andy, The fact that transform, transformValu

[jira] [Commented] (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&focusedCommentId=16688332#comment-16688332 ] Boyang Chen commented on KAFKA-7610: Hey [~enether] great summary! I'm also in favor

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

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

[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&focusedCommentId=16688175#comment-16688175 ] Stephane Maarek commented on KAFKA-1194: That's okay Here's another test case yo

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

[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 ScramLoginModul

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

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

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

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

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

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

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

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

[jira] [Commented] (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&focusedCommentId=16687763#comment-16687763 ] Stanislav Kozlovski commented on KAFKA-7610: Hey everybody, The static membe

[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&focusedCommentId=16687631#comment-16687631 ] Andras Beni commented on KAFKA-7631: [~asasvari], [~viktorsomogyi] you might want to

[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