[
https://issues.apache.org/jira/browse/KAFKA-4829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049834#comment-16049834
]
Jeyhun Karimov commented on KAFKA-4829:
---
[~guozhang] I would suggest similar model to SQL Server's
[
https://issues.apache.org/jira/browse/KAFKA-3907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeyhun Karimov reassigned KAFKA-3907:
-
Assignee: Jeyhun Karimov
> Better support for user-specific committing in the Streams
[
https://issues.apache.org/jira/browse/KAFKA-3826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16046497#comment-16046497
]
Jeyhun Karimov edited comment on KAFKA-3826 at 6/12/17 12:32 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-3826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16046497#comment-16046497
]
Jeyhun Karimov commented on KAFKA-3826:
---
[~guozhang] I think KAFKA-4829 also can be related to this
[
https://issues.apache.org/jira/browse/KAFKA-4653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeyhun Karimov reassigned KAFKA-4653:
-
Assignee: Jeyhun Karimov
> Improve test coverage of RocksDBStore
>
[
https://issues.apache.org/jira/browse/KAFKA-4658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeyhun Karimov reassigned KAFKA-4658:
-
Assignee: Jeyhun Karimov
> Improve test coverage InMemoryKeyValueLoggedStore
>
[
https://issues.apache.org/jira/browse/KAFKA-4659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeyhun Karimov reassigned KAFKA-4659:
-
Assignee: Jeyhun Karimov
> Improve test coverage of CachingKeyValueStore
>
[
https://issues.apache.org/jira/browse/KAFKA-4655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeyhun Karimov reassigned KAFKA-4655:
-
Assignee: Jeyhun Karimov
> Improve test coverage of CompositeReadOnlySessionStore
>
[
https://issues.apache.org/jira/browse/KAFKA-4661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeyhun Karimov reassigned KAFKA-4661:
-
Assignee: Jeyhun Karimov
> Improve test coverage UsePreviousTimeOnInvalidTimestamp
>
[
https://issues.apache.org/jira/browse/KAFKA-4325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16035688#comment-16035688
]
Jeyhun Karimov commented on KAFKA-4325:
---
[~mjsax], would this jira requre KIP?
> Improve
[
https://issues.apache.org/jira/browse/KAFKA-4304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16027964#comment-16027964
]
Jeyhun Karimov edited comment on KAFKA-4304 at 5/28/17 10:34 PM:
-
>From
[
https://issues.apache.org/jira/browse/KAFKA-4304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeyhun Karimov reassigned KAFKA-4304:
-
Assignee: Jeyhun Karimov
> Extend Interactive Queries for return latest update timestamp
[
https://issues.apache.org/jira/browse/KAFKA-4304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16027964#comment-16027964
]
Jeyhun Karimov edited comment on KAFKA-4304 at 5/28/17 10:25 PM:
-
>From
[
https://issues.apache.org/jira/browse/KAFKA-4304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16027964#comment-16027964
]
Jeyhun Karimov commented on KAFKA-4304:
---
>From the user perspective, one would query
[
https://issues.apache.org/jira/browse/KAFKA-4304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16027958#comment-16027958
]
Jeyhun Karimov commented on KAFKA-4304:
---
[~mjsax] I completely forgot this issue. Sorry for super
[
https://issues.apache.org/jira/browse/KAFKA-4785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16017575#comment-16017575
]
Jeyhun Karimov commented on KAFKA-4785:
---
[~mjsax] Thanks for reminding. I am on it
> Records from
[
https://issues.apache.org/jira/browse/KAFKA-4785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15989838#comment-15989838
]
Jeyhun Karimov edited comment on KAFKA-4785 at 4/29/17 6:08 PM:
[~mjsax],
[
https://issues.apache.org/jira/browse/KAFKA-3745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15989988#comment-15989988
]
Jeyhun Karimov commented on KAFKA-3745:
---
[~sree2k] is there an update on issue?
> Consider adding
[
https://issues.apache.org/jira/browse/KAFKA-4785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15989838#comment-15989838
]
Jeyhun Karimov commented on KAFKA-4785:
---
[~mjsax], as it is discussed in KAFKA-4218 , we can group
[
https://issues.apache.org/jira/browse/KAFKA-4218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15989837#comment-15989837
]
Jeyhun Karimov commented on KAFKA-4218:
---
[~mjsax], thanks for your comments. I absolutely agree on
[
https://issues.apache.org/jira/browse/KAFKA-4218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeyhun Karimov reassigned KAFKA-4218:
-
Assignee: Jeyhun Karimov
> Enable access to key in ValueTransformer
>
[
https://issues.apache.org/jira/browse/KAFKA-4785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15989557#comment-15989557
]
Jeyhun Karimov commented on KAFKA-4785:
---
[~mjsax] Do you think KAFKA-4144 is blocking for this
[
https://issues.apache.org/jira/browse/KAFKA-4785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeyhun Karimov reassigned KAFKA-4785:
-
Assignee: Jeyhun Karimov
> Records from internal repartitioning topics should always use
[
https://issues.apache.org/jira/browse/KAFKA-4144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15983515#comment-15983515
]
Jeyhun Karimov commented on KAFKA-4144:
---
[~mjsax] I am sorry, I didn't read your email carefully. My
[
https://issues.apache.org/jira/browse/KAFKA-4144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeyhun Karimov updated KAFKA-4144:
--
Status: Reopened (was: Closed)
> Allow per stream/table timestamp extractor
>
[
https://issues.apache.org/jira/browse/KAFKA-4144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeyhun Karimov closed KAFKA-4144.
-
> Allow per stream/table timestamp extractor
> --
>
>
[
https://issues.apache.org/jira/browse/KAFKA-4144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeyhun Karimov resolved KAFKA-4144.
---
Resolution: Fixed
Reviewer: Matthias J. Sax
> Allow per stream/table timestamp
[
https://issues.apache.org/jira/browse/KAFKA-4144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837350#comment-15837350
]
Jeyhun Karimov commented on KAFKA-4144:
---
Thanks for clarification. I got the point.
> Allow per
[
https://issues.apache.org/jira/browse/KAFKA-4144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15836328#comment-15836328
]
Jeyhun Karimov edited comment on KAFKA-4144 at 1/24/17 8:58 PM:
[~mjsax]
[
https://issues.apache.org/jira/browse/KAFKA-4144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833708#comment-15833708
]
Jeyhun Karimov commented on KAFKA-4144:
---
[~elevy] I am not sure I got your point. Please correct me
[
https://issues.apache.org/jira/browse/KAFKA-4304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833607#comment-15833607
]
Jeyhun Karimov commented on KAFKA-4304:
---
[~mjsax] Can we generalize this feature to {{top-k}}
[
https://issues.apache.org/jira/browse/KAFKA-4613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeyhun Karimov reassigned KAFKA-4613:
-
Assignee: Jeyhun Karimov
> Treat null-key records the same way for joins and aggreations
[
https://issues.apache.org/jira/browse/KAFKA-4144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833131#comment-15833131
]
Jeyhun Karimov edited comment on KAFKA-4144 at 1/22/17 3:06 PM:
[~elevy]
[
https://issues.apache.org/jira/browse/KAFKA-4144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833131#comment-15833131
]
Jeyhun Karimov edited comment on KAFKA-4144 at 1/22/17 3:05 PM:
[~elevy]
[
https://issues.apache.org/jira/browse/KAFKA-3835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeyhun Karimov reassigned KAFKA-3835:
-
Assignee: Jeyhun Karimov
> Streams is creating two ProducerRecords for each send via
[
https://issues.apache.org/jira/browse/KAFKA-4144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833131#comment-15833131
]
Jeyhun Karimov commented on KAFKA-4144:
---
[~elevy] Shouldn't it be per partitioned stream/table? So,
[
https://issues.apache.org/jira/browse/KAFKA-4144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeyhun Karimov reassigned KAFKA-4144:
-
Assignee: Jeyhun Karimov
> Allow per stream/table timestamp extractor
>
[
https://issues.apache.org/jira/browse/KAFKA-3856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-3856 started by Jeyhun Karimov.
-
> Move inner classes accessible only functions in TopologyBuilder out of
[
https://issues.apache.org/jira/browse/KAFKA-3825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeyhun Karimov updated KAFKA-3825:
--
Status: Patch Available (was: Open)
> Allow users to specify different types of state stores
[
https://issues.apache.org/jira/browse/KAFKA-3825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15494574#comment-15494574
]
Jeyhun Karimov commented on KAFKA-3825:
---
I am closing this issue as the PR has already been
[
https://issues.apache.org/jira/browse/KAFKA-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeyhun Karimov updated KAFKA-3184:
--
Assignee: Guozhang Wang (was: Jeyhun Karimov)
> Add Checkpoint for In-memory State Store
>
[
https://issues.apache.org/jira/browse/KAFKA-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeyhun Karimov updated KAFKA-3184:
--
Assignee: (was: Guozhang Wang)
> Add Checkpoint for In-memory State Store
>
[
https://issues.apache.org/jira/browse/KAFKA-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeyhun Karimov reassigned KAFKA-3184:
-
Assignee: Jeyhun Karimov
> Add Checkpoint for In-memory State Store
>
[
https://issues.apache.org/jira/browse/KAFKA-3856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeyhun Karimov reassigned KAFKA-3856:
-
Assignee: Jeyhun Karimov
> Move inner classes accessible only functions in
[
https://issues.apache.org/jira/browse/KAFKA-3825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15350110#comment-15350110
]
Jeyhun Karimov commented on KAFKA-3825:
---
[~guozhang] I am starting on this issue and I would to get
[
https://issues.apache.org/jira/browse/KAFKA-3825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeyhun Karimov reassigned KAFKA-3825:
-
Assignee: Jeyhun Karimov
> Allow users to specify different types of state stores in
[
https://issues.apache.org/jira/browse/KAFKA-3836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeyhun Karimov reassigned KAFKA-3836:
-
Assignee: Jeyhun Karimov
> KStreamReduce and KTableReduce should not pass nulls to
[
https://issues.apache.org/jira/browse/KAFKA-3839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15336310#comment-15336310
]
Jeyhun Karimov commented on KAFKA-3839:
---
It seems that groupby operator is gone from KTable.
[
https://issues.apache.org/jira/browse/KAFKA-3839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-3839 started by Jeyhun Karimov.
-
> Handling null keys in KTable.groupBy
>
[
https://issues.apache.org/jira/browse/KAFKA-3839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15330865#comment-15330865
]
Jeyhun Karimov commented on KAFKA-3839:
---
I can take this task as a starter.
> Handling null keys in
50 matches
Mail list logo
