[jira] [Comment Edited] (KAFKA-6599) KTable KTable join semantics violated when caching enabled

2022-09-09 Thread Jan Filipiak (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17600611#comment-17600611 ] Jan Filipiak edited comment on KAFKA-6599 at 9/9/22 9:07 AM: - Just jumping in

[jira] [Commented] (KAFKA-6599) KTable KTable join semantics violated when caching enabled

2022-09-06 Thread Jan Filipiak (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17600611#comment-17600611 ] Jan Filipiak commented on KAFKA-6599: - Just jumping in here as I'm prepping with this included now.

[jira] [Comment Edited] (KAFKA-9031) Add possibility to reset Kafka streams application state to specific point in time

2019-10-16 Thread Jan Filipiak (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16952652#comment-16952652 ] Jan Filipiak edited comment on KAFKA-9031 at 10/16/19 9:33 AM: ---

[jira] [Comment Edited] (KAFKA-9031) Add possibility to reset Kafka streams application state to specific point in time

2019-10-16 Thread Jan Filipiak (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16952652#comment-16952652 ] Jan Filipiak edited comment on KAFKA-9031 at 10/16/19 9:32 AM: ---

[jira] [Commented] (KAFKA-9031) Add possibility to reset Kafka streams application state to specific point in time

2019-10-16 Thread Jan Filipiak (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16952652#comment-16952652 ] Jan Filipiak commented on KAFKA-9031: - Recommendation from my side to leave this feature out. The

[jira] [Comment Edited] (KAFKA-7658) Add KStream#toTable to the Streams DSL

2018-11-19 Thread Jan Filipiak (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692791#comment-16692791 ] Jan Filipiak edited comment on KAFKA-7658 at 11/20/18 7:46 AM: --- [~guozhang]

[jira] [Commented] (KAFKA-7658) Add KStream#toTable to the Streams DSL

2018-11-19 Thread Jan Filipiak (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692791#comment-16692791 ] Jan Filipiak commented on KAFKA-7658: - [~guozhang] I remember our conversations when DSL 1.0 was

[jira] [Created] (KAFKA-6599) KTable KTable join semantics violated when caching enabled

2018-02-27 Thread Jan Filipiak (JIRA)
Jan Filipiak created KAFKA-6599: --- Summary: KTable KTable join semantics violated when caching enabled Key: KAFKA-6599 URL: https://issues.apache.org/jira/browse/KAFKA-6599 Project: Kafka Issue

[jira] [Commented] (KAFKA-6442) Catch 22 with cluster rebalancing

2018-01-11 Thread Jan Filipiak (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16323021#comment-16323021 ] Jan Filipiak commented on KAFKA-6442: - I guess discussing this on the mailing-list / slack first could

[jira] [Commented] (KAFKA-3705) Support non-key joining in KTable

2017-11-10 Thread Jan Filipiak (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16247892#comment-16247892 ] Jan Filipiak commented on KAFKA-3705: - [~thuey100] I am glad to see your interest in this. The pull

[jira] [Commented] (KAFKA-3705) Support non-key joining in KTable

2017-10-25 Thread Jan Filipiak (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16218247#comment-16218247 ] Jan Filipiak commented on KAFKA-3705: - Just my few sense. In 0.10.0.1 (what we use) it was easier as

[jira] [Commented] (KAFKA-6056) LogCleaner always cleaning into 1 Segment per sizegroup might exeed relativ offset range

2017-10-11 Thread Jan Filipiak (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16201455#comment-16201455 ] Jan Filipiak commented on KAFKA-6056: - A valid workaround for partitions containing the segments

[jira] [Commented] (KAFKA-6056) LogCleaner always cleaning into 1 Segment per sizegroup might exeed relativ offset range

2017-10-11 Thread Jan Filipiak (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16201451#comment-16201451 ] Jan Filipiak commented on KAFKA-6056: - Besides not mentioned in the comment, the code actually checks

[jira] [Created] (KAFKA-6056) LogCleaner always cleaning into 1 Segment might exeed relativ offset range

2017-10-11 Thread Jan Filipiak (JIRA)
Jan Filipiak created KAFKA-6056: --- Summary: LogCleaner always cleaning into 1 Segment might exeed relativ offset range Key: KAFKA-6056 URL: https://issues.apache.org/jira/browse/KAFKA-6056 Project:

[jira] [Updated] (KAFKA-6056) LogCleaner always cleaning into 1 Segment per sizegroup might exeed relativ offset range

2017-10-11 Thread Jan Filipiak (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jan Filipiak updated KAFKA-6056: Summary: LogCleaner always cleaning into 1 Segment per sizegroup might exeed relativ offset range