[
https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16853118#comment-16853118
]
Mateusz Owczarek commented on KAFKA-7994:
-
Bruno's example above indicates it actually does
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16842015#comment-16842015
]
Mateusz Owczarek commented on KAFKA-5998:
-
[~guozhang] Any updates on this? I have the same
[
https://issues.apache.org/jira/browse/KAFKA-7882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16769611#comment-16769611
]
Mateusz Owczarek commented on KAFKA-7882:
-
Late record as I understand (correct me if I'm wrong)
[
https://issues.apache.org/jira/browse/KAFKA-7882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16769321#comment-16769321
]
Mateusz Owczarek commented on KAFKA-7882:
-
I am using this approach only after window aggregation
[
https://issues.apache.org/jira/browse/KAFKA-7882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16768597#comment-16768597
]
Mateusz Owczarek commented on KAFKA-7882:
-
I understand that, I'm familiar with the wall-clock vs
[
https://issues.apache.org/jira/browse/KAFKA-7882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16768064#comment-16768064
]
Mateusz Owczarek commented on KAFKA-7882:
-
Yes, we can, but there is still one unanswered
[
https://issues.apache.org/jira/browse/KAFKA-7882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767006#comment-16767006
]
Mateusz Owczarek commented on KAFKA-7882:
-
[~mjsax]
As I reported, I was using Kafka Streams
[
https://issues.apache.org/jira/browse/KAFKA-7882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16765967#comment-16765967
]
Mateusz Owczarek commented on KAFKA-7882:
-
[~vvcephei]
This is pretty much, how do I call
[
https://issues.apache.org/jira/browse/KAFKA-7882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16764999#comment-16764999
]
Mateusz Owczarek commented on KAFKA-7882:
-
Sorry for bumping post, but any advice on creating
[
https://issues.apache.org/jira/browse/KAFKA-7882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16761758#comment-16761758
]
Mateusz Owczarek edited comment on KAFKA-7882 at 2/11/19 2:16 PM:
--
Also,
[
https://issues.apache.org/jira/browse/KAFKA-7882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16761758#comment-16761758
]
Mateusz Owczarek commented on KAFKA-7882:
-
Also, I noticed my regression tests checking if events
[
https://issues.apache.org/jira/browse/KAFKA-7882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16761706#comment-16761706
]
Mateusz Owczarek commented on KAFKA-7882:
-
Hey [~vvcephei], thanks for the answer! I've upgraded
[
https://issues.apache.org/jira/browse/KAFKA-7882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mateusz Owczarek updated KAFKA-7882:
Description:
Hello, I have a problem with the state store being closed frequently while
[
https://issues.apache.org/jira/browse/KAFKA-7882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mateusz Owczarek updated KAFKA-7882:
Description:
Hello, I have a problem with the state store being closed frequently while
[
https://issues.apache.org/jira/browse/KAFKA-7882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mateusz Owczarek updated KAFKA-7882:
Description:
Hello, I have a problem with the state store being closed frequently while
Mateusz Owczarek created KAFKA-7882:
---
Summary: StateStores are frequently closed during the 'transform'
method
Key: KAFKA-7882
URL: https://issues.apache.org/jira/browse/KAFKA-7882
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-7882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mateusz Owczarek updated KAFKA-7882:
Description:
Hello, I have a problem with the state store being closed frequently while
[
https://issues.apache.org/jira/browse/KAFKA-7753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16725955#comment-16725955
]
Mateusz Owczarek commented on KAFKA-7753:
-
I see, thanks for quick answer, closing the issue ;)
[
https://issues.apache.org/jira/browse/KAFKA-7753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mateusz Owczarek resolved KAFKA-7753.
-
Resolution: Feedback Received
> ValueTransformerWithKey should not require producing one
[
https://issues.apache.org/jira/browse/KAFKA-7753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16725902#comment-16725902
]
Mateusz Owczarek commented on KAFKA-7753:
-
Actually it would be fine, but because I missread
Mateusz Owczarek created KAFKA-7753:
---
Summary: ValueTransformerWithKey should not require producing one
value every message
Key: KAFKA-7753
URL: https://issues.apache.org/jira/browse/KAFKA-7753
[
https://issues.apache.org/jira/browse/KAFKA-7669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16696653#comment-16696653
]
Mateusz Owczarek commented on KAFKA-7669:
-
Thank you for the answer, I figured out that the
[
https://issues.apache.org/jira/browse/KAFKA-7669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mateusz Owczarek updated KAFKA-7669:
Issue Type: Wish (was: Bug)
> Stream topology definition is not robust to the ordering
[
https://issues.apache.org/jira/browse/KAFKA-7669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mateusz Owczarek updated KAFKA-7669:
Summary: Stream topology definition is not robust to the ordering changes
(was: Stream
Mateusz Owczarek created KAFKA-7669:
---
Summary: Stream topology definition is not prune to the ordering
changes
Key: KAFKA-7669
URL: https://issues.apache.org/jira/browse/KAFKA-7669
Project: Kafka
25 matches
Mail list logo
