[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16846566#comment-16846566
]
Andrew edited comment on KAFKA-5998 at 5/23/19 11:32 AM:
-
I have just seen this
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16846566#comment-16846566
]
Andrew edited comment on KAFKA-5998 at 5/23/19 9:29 AM:
I have just seen this
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16846566#comment-16846566
]
Andrew commented on KAFKA-5998:
---
I have just seen this error with kafka 2.2.0 and confluent 5.2.1. We are
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16841640#comment-16841640
]
Andrew edited comment on KAFKA-8315 at 5/16/19 6:55 PM:
Also, I had a thought
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16841640#comment-16841640
]
Andrew commented on KAFKA-8315:
---
Also, I had a thought whether you could modify
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16841611#comment-16841611
]
Andrew edited comment on KAFKA-8315 at 5/16/19 6:40 PM:
Well, Im not sure that
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16841611#comment-16841611
]
Andrew edited comment on KAFKA-8315 at 5/16/19 6:32 PM:
Well, Im not sure that
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16841611#comment-16841611
]
Andrew edited comment on KAFKA-8315 at 5/16/19 6:30 PM:
Well, Im not sure that
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16841611#comment-16841611
]
Andrew edited comment on KAFKA-8315 at 5/16/19 6:29 PM:
Well, Im not sure that
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16841611#comment-16841611
]
Andrew edited comment on KAFKA-8315 at 5/16/19 6:28 PM:
Well, Im not sure that
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16841611#comment-16841611
]
Andrew edited comment on KAFKA-8315 at 5/16/19 6:16 PM:
Well, Im not sure that
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16841611#comment-16841611
]
Andrew commented on KAFKA-8315:
---
Well, Im not sure that just fixing the start is sufficient. I suspect that
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16841449#comment-16841449
]
Andrew commented on KAFKA-8315:
---
[~mjsax] [~vvcephei] [~ableegoldman] Thanks for your help on this, I think
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16841273#comment-16841273
]
Andrew commented on KAFKA-8315:
---
Ha!, you are absolutely right. Maybe I didn't understand the significance
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16841213#comment-16841213
]
Andrew commented on KAFKA-8315:
---
[~vvcephei] [~ableegoldman] Using the integration test I think I now
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16840541#comment-16840541
]
Andrew commented on KAFKA-8315:
---
[~vvcephei] [~ableegoldman] I have constructed an integration test that I
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16839711#comment-16839711
]
Andrew commented on KAFKA-8315:
---
I constructed a super-ugly workaround for my \{{join-example}} demo app.
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16839703#comment-16839703
]
Andrew commented on KAFKA-8315:
---
I constructed a super-ugly workaround for my \{{join-example}} demo app.
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew updated KAFKA-8315:
--
Description:
The problem we are experiencing is that we cannot reliably perform simple joins
over
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew updated KAFKA-8315:
--
Description:
The problem we are experiencing is that we cannot reliably perform simple joins
over
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew updated KAFKA-8315:
--
Description:
The problem we are experiencing is that we cannot reliably perform simple joins
over
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew updated KAFKA-8315:
--
Description:
The problem we are experiencing is that we cannot reliably perform simple joins
over
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew updated KAFKA-8315:
--
Description:
The problem we are experiencing is that we cannot reliably perform simple joins
over
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew updated KAFKA-8315:
--
Description:
The problem we are experiencing is that we cannot reliably perform simple joins
over
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew updated KAFKA-8315:
--
Description:
The problem we are experiencing is that we cannot reliably perform simple joins
over
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew updated KAFKA-8315:
--
Description:
The problem we are experiencing is that we cannot reliably perform simple joins
over
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew updated KAFKA-8315:
--
Description:
The problem we are experiencing is that we cannot reliably perform simple joins
over
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew updated KAFKA-8315:
--
Description:
The problem we are experiencing is that we cannot reliably perform simple joins
over
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew updated KAFKA-8315:
--
Description:
The problem we are experiencing is that we cannot reliably perform simple joins
over
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew updated KAFKA-8315:
--
Summary: Historical join issues (was: Cannot pass Materialized into a join
operation - hence cant set
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16838783#comment-16838783
]
Andrew commented on KAFKA-8315:
---
Thanks [~vvcephei], I am running the unit tests in the kafka project. I
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16838565#comment-16838565
]
Andrew edited comment on KAFKA-8315 at 5/13/19 3:52 PM:
This is the test enhanced
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16838565#comment-16838565
]
Andrew edited comment on KAFKA-8315 at 5/13/19 3:45 PM:
This is the test enhanced
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16838565#comment-16838565
]
Andrew edited comment on KAFKA-8315 at 5/13/19 2:17 PM:
This is the test enhanced
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16838565#comment-16838565
]
Andrew commented on KAFKA-8315:
---
This is the test enhanced to use timestamp extraction, and it works ;
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16838550#comment-16838550
]
Andrew edited comment on KAFKA-8315 at 5/13/19 1:50 PM:
This test appears to work
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16838550#comment-16838550
]
Andrew edited comment on KAFKA-8315 at 5/13/19 1:48 PM:
This test appears to work
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16838550#comment-16838550
]
Andrew edited comment on KAFKA-8315 at 5/13/19 1:48 PM:
This test appears to work
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16838550#comment-16838550
]
Andrew commented on KAFKA-8315:
---
This test appears to work ok
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16838471#comment-16838471
]
Andrew edited comment on KAFKA-8315 at 5/13/19 12:52 PM:
-
[~vvcephei]
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16838471#comment-16838471
]
Andrew commented on KAFKA-8315:
---
[~vvcephei] [~ableegoldman] I was just looking at the unit tests for
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16838012#comment-16838012
]
Andrew edited comment on KAFKA-8315 at 5/13/19 7:10 AM:
[~ableegoldman] Right, I
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16838012#comment-16838012
]
Andrew commented on KAFKA-8315:
---
[~ableegoldman] Right, I see what you mean, this loop only goes until the
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16837086#comment-16837086
]
Andrew edited comment on KAFKA-8315 at 5/10/19 9:48 AM:
[~ableegoldman]
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16837086#comment-16837086
]
Andrew edited comment on KAFKA-8315 at 5/10/19 9:47 AM:
[~ableegoldman]
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16837086#comment-16837086
]
Andrew edited comment on KAFKA-8315 at 5/10/19 9:43 AM:
[~ableegoldman]
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16837086#comment-16837086
]
Andrew edited comment on KAFKA-8315 at 5/10/19 9:42 AM:
[~ableegoldman]
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16837086#comment-16837086
]
Andrew edited comment on KAFKA-8315 at 5/10/19 9:42 AM:
[~ableegoldman]
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16837086#comment-16837086
]
Andrew edited comment on KAFKA-8315 at 5/10/19 9:42 AM:
[~ableegoldman]
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16837086#comment-16837086
]
Andrew edited comment on KAFKA-8315 at 5/10/19 9:40 AM:
[~ableegoldman]
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16837086#comment-16837086
]
Andrew edited comment on KAFKA-8315 at 5/10/19 9:32 AM:
[~ableegoldman]
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16837086#comment-16837086
]
Andrew edited comment on KAFKA-8315 at 5/10/19 9:31 AM:
[~ableegoldman]
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16837086#comment-16837086
]
Andrew edited comment on KAFKA-8315 at 5/10/19 9:27 AM:
[~ableegoldman]
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16837086#comment-16837086
]
Andrew edited comment on KAFKA-8315 at 5/10/19 9:26 AM:
[~ableegoldman] Can I
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16837086#comment-16837086
]
Andrew commented on KAFKA-8315:
---
[~ableegoldman] Can I sanity check my understanding here. From what I can
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16836735#comment-16836735
]
Andrew edited comment on KAFKA-8315 at 5/9/19 10:04 PM:
Thanks [~ableegoldman]
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16836735#comment-16836735
]
Andrew edited comment on KAFKA-8315 at 5/9/19 10:03 PM:
Thanks [~ableegoldman]
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16836735#comment-16836735
]
Andrew edited comment on KAFKA-8315 at 5/9/19 9:59 PM:
---
Thanks [~ableegoldman] and
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16836735#comment-16836735
]
Andrew commented on KAFKA-8315:
---
Thanks [~ableegoldman] and [~vvcephei].
I have today tried to isolate the
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16836278#comment-16836278
]
Andrew edited comment on KAFKA-8315 at 5/9/19 10:58 AM:
[~vvcephei] Thanks again
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16836278#comment-16836278
]
Andrew edited comment on KAFKA-8315 at 5/9/19 10:57 AM:
Ok, so it should work as
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16836278#comment-16836278
]
Andrew edited comment on KAFKA-8315 at 5/9/19 10:57 AM:
Ok, so it should work as
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16836278#comment-16836278
]
Andrew edited comment on KAFKA-8315 at 5/9/19 10:56 AM:
Ok, so it should work as
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16836278#comment-16836278
]
Andrew edited comment on KAFKA-8315 at 5/9/19 10:43 AM:
Ok, so it should work as
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16836278#comment-16836278
]
Andrew commented on KAFKA-8315:
---
Ok, so it should work as I had previously hoped, so maybe our working
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16835784#comment-16835784
]
Andrew edited comment on KAFKA-8315 at 5/8/19 5:54 PM:
---
After a lot of
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16835784#comment-16835784
]
Andrew commented on KAFKA-8315:
---
After a lot of investigation, we think this issue is down to the fact that
[
https://issues.apache.org/jira/browse/KAFKA-8317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16835391#comment-16835391
]
Andrew commented on KAFKA-8317:
---
Ok thanks for the reply. I will try this later. What surprises me though,
[
https://issues.apache.org/jira/browse/KAFKA-8317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16835390#comment-16835390
]
Andrew commented on KAFKA-8317:
---
Ok thanks for the reply. I will try this later. What surprises me though,
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16833161#comment-16833161
]
Andrew commented on KAFKA-8315:
---
I have run a join by removing the timestamp transform and the aggregation
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16833088#comment-16833088
]
Andrew edited comment on KAFKA-8315 at 5/4/19 3:53 PM:
---
Ive attached my code:
* I
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16833088#comment-16833088
]
Andrew edited comment on KAFKA-8315 at 5/4/19 3:53 PM:
---
Ive attached my code:
* I
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16833088#comment-16833088
]
Andrew commented on KAFKA-8315:
---
Ive attached my code:
* I have logging in the ValueJoiner so I can see
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16833088#comment-16833088
]
Andrew edited comment on KAFKA-8315 at 5/4/19 3:51 PM:
---
Ive attached my code:
* I
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew updated KAFKA-8315:
--
Attachment: code.java
> Cannot pass Materialized into a join operation - hence cant set retention
> period
[
https://issues.apache.org/jira/browse/KAFKA-8317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16833060#comment-16833060
]
Andrew edited comment on KAFKA-8317 at 5/4/19 1:32 PM:
---
[~vvcephei] Here is the
[
https://issues.apache.org/jira/browse/KAFKA-8317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16833060#comment-16833060
]
Andrew edited comment on KAFKA-8317 at 5/4/19 1:29 PM:
---
[~vvcephei] Here is the
[
https://issues.apache.org/jira/browse/KAFKA-8317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16833060#comment-16833060
]
Andrew commented on KAFKA-8317:
---
[~vvcephei] Here is the code snippet
```
private static Topology
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16832577#comment-16832577
]
Andrew edited comment on KAFKA-8315 at 5/3/19 6:54 PM:
---
[~vvcephei] Update I ran
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16832577#comment-16832577
]
Andrew edited comment on KAFKA-8315 at 5/3/19 6:54 PM:
---
[~vvcephei] Update I ran
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16832577#comment-16832577
]
Andrew edited comment on KAFKA-8315 at 5/3/19 6:34 PM:
---
[~vvcephei] Update I ran
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16832577#comment-16832577
]
Andrew edited comment on KAFKA-8315 at 5/3/19 6:21 PM:
---
[~vvcephei] Update I ran
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16832577#comment-16832577
]
Andrew edited comment on KAFKA-8315 at 5/3/19 5:32 PM:
---
[~vvcephei] Update I ran
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16832577#comment-16832577
]
Andrew edited comment on KAFKA-8315 at 5/3/19 3:26 PM:
---
[~vvcephei] Update I ran
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16832577#comment-16832577
]
Andrew commented on KAFKA-8315:
---
[~vvcephei] Update I ran using grace = 20D and I see records from around
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16832543#comment-16832543
]
Andrew edited comment on KAFKA-8315 at 5/3/19 3:05 PM:
---
[~vvcephei] Ive been
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16832543#comment-16832543
]
Andrew edited comment on KAFKA-8315 at 5/3/19 3:03 PM:
---
[~vvcephei] Ive been
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16832543#comment-16832543
]
Andrew edited comment on KAFKA-8315 at 5/3/19 2:38 PM:
---
[~vvcephei] Ive been
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16832543#comment-16832543
]
Andrew edited comment on KAFKA-8315 at 5/3/19 2:38 PM:
---
[~vvcephei] Ive been
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16832543#comment-16832543
]
Andrew commented on KAFKA-8315:
---
[~vvcephei] Ive been struggling with this today.
* I have logging on
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16832325#comment-16832325
]
Andrew edited comment on KAFKA-8315 at 5/3/19 1:03 PM:
---
The fudge factor is the
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16832325#comment-16832325
]
Andrew commented on KAFKA-8315:
---
The fudge factor is the \{windowstore.changelog.additional.retention.ms}
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew updated KAFKA-8315:
--
Summary: Cannot pass Materialized into a join operation - hence cant set
retention period independent of grace
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew updated KAFKA-8315:
--
Description:
The documentation says to use `Materialized` not `JoinWindows.until()`
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew updated KAFKA-8315:
--
Description:
The documentation says to use `Materialized` not `JoinWindows.until()`
Andrew created KAFKA-8317:
-
Summary: ClassCastException using KTable.suppress()
Key: KAFKA-8317
URL: https://issues.apache.org/jira/browse/KAFKA-8317
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16831747#comment-16831747
]
Andrew edited comment on KAFKA-8315 at 5/2/19 4:53 PM:
---
I should also mention my
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16831747#comment-16831747
]
Andrew edited comment on KAFKA-8315 at 5/2/19 4:40 PM:
---
I should also mention my
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16831747#comment-16831747
]
Andrew edited comment on KAFKA-8315 at 5/2/19 4:39 PM:
---
I should also mention my
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16831747#comment-16831747
]
Andrew commented on KAFKA-8315:
---
I should also mention my use case from the original slack community
1 - 100 of 104 matches
Mail list logo
