[jira] [Commented] (KAFKA-10383) KTable Join on Foreign key is opinionated

[ https://issues.apache.org/jira/browse/KAFKA-10383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175767#comment-17175767 ] Marco Lotz commented on KAFKA-10383: Cool! That's also a feasible approach - if having a higher

[jira] [Created] (KAFKA-10383) KTable Join on Foreign key is opinionated

Marco Lotz created KAFKA-10383: -- Summary: KTable Join on Foreign key is opinionated Key: KAFKA-10383 URL: https://issues.apache.org/jira/browse/KAFKA-10383 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-10383) KTable Join on Foreign key is opinionated

[ https://issues.apache.org/jira/browse/KAFKA-10383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marco Lotz updated KAFKA-10383: --- Description: *Status Quo:* The current implementation of [KIP-213 

[jira] [Updated] (KAFKA-10383) KTable Join on Foreign key is opinionated

[ https://issues.apache.org/jira/browse/KAFKA-10383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marco Lotz updated KAFKA-10383: --- Description: *Status Quo:* The current implementation of [KIP-213 

[jira] [Updated] (KAFKA-10383) KTable Join on Foreign key is opinionated

[ https://issues.apache.org/jira/browse/KAFKA-10383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marco Lotz updated KAFKA-10383: --- Description: *Status Quo:* The current implementation of [KIP-213 

[jira] [Comment Edited] (KAFKA-9527) Application Reset Tool Returns NPE when --to-datetime or --by-duration are run on --input-topics with empty partitions

[ https://issues.apache.org/jira/browse/KAFKA-9527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278285#comment-17278285 ] Marco Lotz edited comment on KAFKA-9527 at 2/3/21, 6:36 PM: [~mjsax] I see

[jira] [Updated] (KAFKA-9527) Application Reset Tool Returns NPE when --to-datetime or --by-duration are run on --input-topics with empty partitions

[ https://issues.apache.org/jira/browse/KAFKA-9527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marco Lotz updated KAFKA-9527: -- Description: When running the streams application reset tool with --by-duration or --to-datetime if

[jira] [Updated] (KAFKA-9527) Application Reset Tool Returns NPE when --to-datetime or --by-duration are run on --input-topics with empty partitions

[ https://issues.apache.org/jira/browse/KAFKA-9527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marco Lotz updated KAFKA-9527: -- Summary: Application Reset Tool Returns NPE when --to-datetime or --by-duration are run on

[jira] [Commented] (KAFKA-9527) Application Reset Tool Returns NPE when --to-timestamp or --by-duration are run on --input-topics with empty partitions

[ https://issues.apache.org/jira/browse/KAFKA-9527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278285#comment-17278285 ] Marco Lotz commented on KAFKA-9527: --- [~mjsax] I see your point. Indeed in this scenario makes more

[jira] [Comment Edited] (KAFKA-9527) Application Reset Tool Returns NPE when --to-timestamp or --by-duration are run on --input-topics with empty partitions

[ https://issues.apache.org/jira/browse/KAFKA-9527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278285#comment-17278285 ] Marco Lotz edited comment on KAFKA-9527 at 2/3/21, 6:34 PM: [~mjsax] I see

[jira] [Commented] (KAFKA-9527) Application Reset Tool Returns NPE when --to-timestamp or --by-duration are run on --input-topics with empty partitions

[ https://issues.apache.org/jira/browse/KAFKA-9527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276987#comment-17276987 ] Marco Lotz commented on KAFKA-9527: --- [~mjsax] what would be the expected behaviour in this scenario? I

[jira] [Assigned] (KAFKA-9527) Application Reset Tool Returns NPE when --to-datetime or --by-duration are run on --input-topics with empty partitions

[ https://issues.apache.org/jira/browse/KAFKA-9527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marco Lotz reassigned KAFKA-9527: - Assignee: Marco Lotz (was: jbfletch) > Application Reset Tool Returns NPE when --to-datetime

[jira] [Commented] (KAFKA-9527) Application Reset Tool Returns NPE when --to-datetime or --by-duration are run on --input-topics with empty partitions

[ https://issues.apache.org/jira/browse/KAFKA-9527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278825#comment-17278825 ] Marco Lotz commented on KAFKA-9527: --- [~jeqo] Understood. About returning the latest offset - if we

[jira] [Commented] (KAFKA-9527) Application Reset Tool Returns NPE when --to-datetime or --by-duration are run on --input-topics with empty partitions

[ https://issues.apache.org/jira/browse/KAFKA-9527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278849#comment-17278849 ] Marco Lotz commented on KAFKA-9527: --- PR ready. Please let me know your thoughts and what needs changing

[jira] [Assigned] (KAFKA-5676) MockStreamsMetrics should be in o.a.k.test

[ https://issues.apache.org/jira/browse/KAFKA-5676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marco Lotz reassigned KAFKA-5676: - Assignee: Marco Lotz > MockStreamsMetrics should be in o.a.k.test >

[jira] [Comment Edited] (KAFKA-5676) MockStreamsMetrics should be in o.a.k.test

[ https://issues.apache.org/jira/browse/KAFKA-5676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17349475#comment-17349475 ] Marco Lotz edited comment on KAFKA-5676 at 5/21/21, 9:39 PM: - [~mjsax] 

[jira] [Commented] (KAFKA-5676) MockStreamsMetrics should be in o.a.k.test

[ https://issues.apache.org/jira/browse/KAFKA-5676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17349475#comment-17349475 ] Marco Lotz commented on KAFKA-5676: --- [~mjsax]  [~guozhang] I can take over this ticket if nobody minds.

[jira] [Comment Edited] (KAFKA-5676) MockStreamsMetrics should be in o.a.k.test

[ https://issues.apache.org/jira/browse/KAFKA-5676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17349475#comment-17349475 ] Marco Lotz edited comment on KAFKA-5676 at 5/21/21, 9:04 PM: - [~mjsax] 

[jira] [Comment Edited] (KAFKA-5676) MockStreamsMetrics should be in o.a.k.test

[ https://issues.apache.org/jira/browse/KAFKA-5676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17354118#comment-17354118 ] Marco Lotz edited comment on KAFKA-5676 at 5/30/21, 10:47 PM: -- [~mjsax]

[jira] [Commented] (KAFKA-5676) MockStreamsMetrics should be in o.a.k.test

[ https://issues.apache.org/jira/browse/KAFKA-5676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17354118#comment-17354118 ] Marco Lotz commented on KAFKA-5676: --- [~mjsax] [~cadonna] I have spent a reasonable amount of time

[jira] [Assigned] (KAFKA-5676) MockStreamsMetrics should be in o.a.k.test

[ https://issues.apache.org/jira/browse/KAFKA-5676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marco Lotz reassigned KAFKA-5676: - Assignee: (was: Marco Lotz) > MockStreamsMetrics should be in o.a.k.test >

[jira] [Comment Edited] (KAFKA-9524) Default window retention does not consider grace period

[ https://issues.apache.org/jira/browse/KAFKA-9524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17281834#comment-17281834 ] Marco Lotz edited comment on KAFKA-9524 at 2/9/21, 7:29 PM: I have reproduced

[jira] [Comment Edited] (KAFKA-9524) Default window retention does not consider grace period

[ https://issues.apache.org/jira/browse/KAFKA-9524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17281834#comment-17281834 ] Marco Lotz edited comment on KAFKA-9524 at 2/9/21, 7:30 PM: I have reproduced

[jira] [Commented] (KAFKA-5146) Kafka Streams: remove compile dependency on connect-json

[ https://issues.apache.org/jira/browse/KAFKA-5146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17281789#comment-17281789 ] Marco Lotz commented on KAFKA-5146: --- [~mjsax] I recall we had a similar problem when updating to Java

[jira] [Commented] (KAFKA-9524) Default window retention does not consider grace period

[ https://issues.apache.org/jira/browse/KAFKA-9524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17281834#comment-17281834 ] Marco Lotz commented on KAFKA-9524: --- I have reproduced the bug on the Unit Tests and can confirm it.

[jira] [Assigned] (KAFKA-9524) Default window retention does not consider grace period

[ https://issues.apache.org/jira/browse/KAFKA-9524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marco Lotz reassigned KAFKA-9524: - Assignee: Marco Lotz > Default window retention does not consider grace period >

[jira] [Commented] (KAFKA-5146) Kafka Streams: remove compile dependency on connect-json

[ https://issues.apache.org/jira/browse/KAFKA-5146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17282398#comment-17282398 ] Marco Lotz commented on KAFKA-5146: --- [~ableegoldman] sounds good. Would you suggest to create a module

[jira] [Assigned] (KAFKA-10383) KTable Join on Foreign key is opinionated

[ https://issues.apache.org/jira/browse/KAFKA-10383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marco Lotz reassigned KAFKA-10383: -- Assignee: Marco Lotz > KTable Join on Foreign key is opinionated >

[jira] [Commented] (KAFKA-10383) KTable Join on Foreign key is opinionated

[ https://issues.apache.org/jira/browse/KAFKA-10383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17282949#comment-17282949 ] Marco Lotz commented on KAFKA-10383: I have just requested confluence access to create the KIP >

[jira] [Commented] (KAFKA-5146) Kafka Streams: remove compile dependency on connect-json

[ https://issues.apache.org/jira/browse/KAFKA-5146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17315626#comment-17315626 ] Marco Lotz commented on KAFKA-5146: --- [~mjsax] would it be possible for you to have a quick look into

[jira] [Commented] (KAFKA-10383) KTable Join on Foreign key is opinionated

[ https://issues.apache.org/jira/browse/KAFKA-10383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17293166#comment-17293166 ] Marco Lotz commented on KAFKA-10383: [~mjsax] the KIP is available

[jira] [Commented] (KAFKA-5146) Kafka Streams: remove compile dependency on connect-json

[ https://issues.apache.org/jira/browse/KAFKA-5146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17293178#comment-17293178 ] Marco Lotz commented on KAFKA-5146: --- [~ableegoldman] [~mjsax] whenever you have some spare time, can

[jira] [Updated] (KAFKA-10383) KTable Join on Foreign key is opinionated

[ https://issues.apache.org/jira/browse/KAFKA-10383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marco Lotz updated KAFKA-10383: --- Issue Type: New Feature (was: Improvement) > KTable Join on Foreign key is opinionated >

[jira] [Assigned] (KAFKA-5146) Kafka Streams: remove compile dependency on connect-json

[ https://issues.apache.org/jira/browse/KAFKA-5146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marco Lotz reassigned KAFKA-5146: - Assignee: Marco Lotz > Kafka Streams: remove compile dependency on connect-json >

[jira] [Commented] (KAFKA-5146) Kafka Streams: remove compile dependency on connect-json

[ https://issues.apache.org/jira/browse/KAFKA-5146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283829#comment-17283829 ] Marco Lotz commented on KAFKA-5146: --- [~guozhang], [~vvcephei], [~bbejeck], [~mjsax] any of you against

[jira] [Commented] (KAFKA-10383) KTable Join on Foreign key is opinionated

[ https://issues.apache.org/jira/browse/KAFKA-10383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17285225#comment-17285225 ] Marco Lotz commented on KAFKA-10383: [~vvcephei] I have sent the email to Kafka's dev list

[jira] [Assigned] (KAFKA-12943) Bug in Kafka Streams Documentation (Aggregating)

[ https://issues.apache.org/jira/browse/KAFKA-12943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marco Lotz reassigned KAFKA-12943: -- Assignee: Marco Lotz > Bug in Kafka Streams Documentation (Aggregating) >

[jira] [Commented] (KAFKA-12943) Bug in Kafka Streams Documentation (Aggregating)

[ https://issues.apache.org/jira/browse/KAFKA-12943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17563944#comment-17563944 ] Marco Lotz commented on KAFKA-12943: The PR was raised in April and approved twice. Is there