[
https://issues.apache.org/jira/browse/KAFKA-9259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17023596#comment-17023596
]
Omkar Mestry commented on KAFKA-9259:
-
[~vvcephei] what approach do you propose?
> suppress() for
[
https://issues.apache.org/jira/browse/KAFKA-9259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014896#comment-17014896
]
Omkar Mestry commented on KAFKA-9259:
-
[~vvcephei] The KGroupedStreamImpl has a windowed operation
[
https://issues.apache.org/jira/browse/KAFKA-9259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007928#comment-17007928
]
Omkar Mestry commented on KAFKA-9259:
-
[~vvcephei] I went through code and found that in
[
https://issues.apache.org/jira/browse/KAFKA-9259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17005982#comment-17005982
]
Omkar Mestry commented on KAFKA-9259:
-
[~vvcephei] [~mjsax] Is was thinking is there any way to
[
https://issues.apache.org/jira/browse/KAFKA-9259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17002773#comment-17002773
]
Omkar Mestry commented on KAFKA-9259:
-
Hi [~vvcephei], is there any which so that I can reproduce
[
https://issues.apache.org/jira/browse/KAFKA-9259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000668#comment-17000668
]
Omkar Mestry commented on KAFKA-9259:
-
So should I work on KAFKA-9260 as this would solve the current
[
https://issues.apache.org/jira/browse/KAFKA-9259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Omkar Mestry reassigned KAFKA-9259:
---
Assignee: Omkar Mestry
> suppress() for windowed-Serdes does not work with default serdes
>
[
https://issues.apache.org/jira/browse/KAFKA-9259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16996977#comment-16996977
]
Omkar Mestry commented on KAFKA-9259:
-
Can I work on this issue?
> suppress() for windowed-Serdes
[
https://issues.apache.org/jira/browse/KAFKA-2758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16895953#comment-16895953
]
Omkar Mestry commented on KAFKA-2758:
-
Is this issue still open and if open can I assign it to
[
https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16890877#comment-16890877
]
Omkar Mestry commented on KAFKA-7245:
-
Hi [~mjsax], as the method in the WindowStore interface and
[
https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16890347#comment-16890347
]
Omkar Mestry commented on KAFKA-7245:
-
Submitted PR by making appropriate changes.
> Deprecate
[
https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885855#comment-16885855
]
Omkar Mestry commented on KAFKA-7245:
-
So should I start making changes in code for removing the
[
https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877520#comment-16877520
]
Omkar Mestry commented on KAFKA-7245:
-
[~mjsax] as the KIP accepted shall I close this Jira or any
[
https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16872006#comment-16872006
]
Omkar Mestry commented on KAFKA-7245:
-
[~mjsax] I have updated the status of [KIP -
[
https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16848387#comment-16848387
]
Omkar Mestry commented on KAFKA-7245:
-
Thread:-
[
https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16848072#comment-16848072
]
Omkar Mestry commented on KAFKA-7245:
-
Added KIP Please review it
> Deprecate WindowStore#put(key,
[
https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Omkar Mestry updated KAFKA-7245:
Description:
We want to remove `WindowStore#put(key, value)` – for this, we first need to
[
https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Omkar Mestry updated KAFKA-7245:
Comment: was deleted
(was: Please provide permission for the username :- omanges on Confluence so
[
https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16847373#comment-16847373
]
Omkar Mestry commented on KAFKA-7245:
-
Please provide permission for the username :- omanges on
[
https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16846598#comment-16846598
]
Omkar Mestry commented on KAFKA-7245:
-
[~mjsax] The core stream also has some class which are using
[
https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16846402#comment-16846402
]
Omkar Mestry commented on KAFKA-7245:
-
Jira :- https://issues.apache.org/jira/browse/KAFKA-7928
[
https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845839#comment-16845839
]
Omkar Mestry commented on KAFKA-7245:
-
[~mjsax], can you please elaborate on the issue as the KIP is
[
https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845478#comment-16845478
]
Omkar Mestry commented on KAFKA-7245:
-
So we need to update only the tests which have put() call with
[
https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16844764#comment-16844764
]
Omkar Mestry commented on KAFKA-7245:
-
[~mjsax] Please add me to the contributors list, so that I can
24 matches
Mail list logo
