[
https://issues.apache.org/jira/browse/KAFKA-4790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska reopened KAFKA-4790:
-
> Kafka cannot recover after a disk full
> --
>
>
Eno Thereska created KAFKA-5487:
---
Summary: Rolling upgrade test for streams
Key: KAFKA-5487
URL: https://issues.apache.org/jira/browse/KAFKA-5487
Project: Kafka
Issue Type: Bug
Compon
Eno Thereska created KAFKA-5499:
---
Summary: Double check how we handle exceptions when commits fail
Key: KAFKA-5499
URL: https://issues.apache.org/jira/browse/KAFKA-5499
Project: Kafka
Issue Typ
Eno Thereska created KAFKA-5509:
---
Summary: add gradle option for building tarball with test jars
Key: KAFKA-5509
URL: https://issues.apache.org/jira/browse/KAFKA-5509
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-4563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska resolved KAFKA-4563.
-
Resolution: Duplicate
This will be fixed as part of KAFKA-5372
> State transitions error PARTITIO
Eno Thereska created KAFKA-5524:
---
Summary: Streams systems tests should be with EoS
Key: KAFKA-5524
URL: https://issues.apache.org/jira/browse/KAFKA-5524
Project: Kafka
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/KAFKA-5006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska reopened KAFKA-5006:
-
> KeyValueStore.put may throw exception unrelated to the current put attempt
> ---
Eno Thereska created KAFKA-5531:
---
Summary: Check exception handling in all streams tests
Key: KAFKA-5531
URL: https://issues.apache.org/jira/browse/KAFKA-5531
Project: Kafka
Issue Type: Sub-tas
Eno Thereska created KAFKA-5533:
---
Summary: Timestamp-based log compaction
Key: KAFKA-5533
URL: https://issues.apache.org/jira/browse/KAFKA-5533
Project: Kafka
Issue Type: New Feature
Eno Thereska created KAFKA-5552:
---
Summary:
testTransactionalProducerTopicAuthorizationExceptionInCommit fails
Key: KAFKA-5552
URL: https://issues.apache.org/jira/browse/KAFKA-5552
Project: Kafka
Eno Thereska created KAFKA-5569:
---
Summary: Document any changes from this task
Key: KAFKA-5569
URL: https://issues.apache.org/jira/browse/KAFKA-5569
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-5566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska reopened KAFKA-5566:
-
> Instable test QueryableStateIntegrationTest.shouldAllowToQueryAfterThreadDied
>
[
https://issues.apache.org/jira/browse/KAFKA-5217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska resolved KAFKA-5217.
-
Resolution: Duplicate
> Improve Streams internal exception handling
>
[
https://issues.apache.org/jira/browse/KAFKA-5302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska resolved KAFKA-5302.
-
Resolution: Won't Fix
> Improve exception handling on streams client (communication with brokers)
[
https://issues.apache.org/jira/browse/KAFKA-5300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska resolved KAFKA-5300.
-
Resolution: Duplicate
Duplicate of KAFKA-5006
> Improve exception handling on producer path
> ---
[
https://issues.apache.org/jira/browse/KAFKA-5301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska resolved KAFKA-5301.
-
Resolution: Won't Fix
> Improve exception handling on consumer path
>
Eno Thereska created KAFKA-5701:
---
Summary: Unit test
shouldTogglePrepareForBulkLoadDuringRestoreCalls fails
Key: KAFKA-5701
URL: https://issues.apache.org/jira/browse/KAFKA-5701
Project: Kafka
Eno Thereska created KAFKA-5725:
---
Summary: Additional failure testing for streams with bouncing
brokers
Key: KAFKA-5725
URL: https://issues.apache.org/jira/browse/KAFKA-5725
Project: Kafka
Iss
Eno Thereska created KAFKA-5733:
---
Summary: System tests get exception RocksDBException: db has more
levels than options.num_levels
Key: KAFKA-5733
URL: https://issues.apache.org/jira/browse/KAFKA-5733
P
[
https://issues.apache.org/jira/browse/KAFKA-5571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska resolved KAFKA-5571.
-
Resolution: Fixed
> Possible deadlock during shutdown in setState in kafka streams 10.2
>
[
https://issues.apache.org/jira/browse/KAFKA-3101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska reassigned KAFKA-3101:
---
Assignee: Eno Thereska
> Optimize Aggregation Outputs
>
>
>
[
https://issues.apache.org/jira/browse/KAFKA-3511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15286364#comment-15286364
]
Eno Thereska commented on KAFKA-3511:
-
[~imandhan] Thanks for picking this up. Is it o
[
https://issues.apache.org/jira/browse/KAFKA-3511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska reassigned KAFKA-3511:
---
Assignee: Eno Thereska (was: Ishita Mandhan)
> Add common aggregation functions like Sum and
[
https://issues.apache.org/jira/browse/KAFKA-3511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-3511 started by Eno Thereska.
---
> Add common aggregation functions like Sum and Avg as build-ins in Kafka
> Stream
[
https://issues.apache.org/jira/browse/KAFKA-3511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska resolved KAFKA-3511.
-
Resolution: Won't Fix
> Add common aggregation functions like Sum and Avg as build-ins in Kafka
>
[
https://issues.apache.org/jira/browse/KAFKA-3511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-3511 stopped by Eno Thereska.
---
> Add common aggregation functions like Sum and Avg as build-ins in Kafka
> Stream
[
https://issues.apache.org/jira/browse/KAFKA-3511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15301718#comment-15301718
]
Eno Thereska commented on KAFKA-3511:
-
>From feedback, it's probably best to hold off
[
https://issues.apache.org/jira/browse/KAFKA-3637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15304171#comment-15304171
]
Eno Thereska commented on KAFKA-3637:
-
Hi [~tszym]. I just added a method that might h
[
https://issues.apache.org/jira/browse/KAFKA-3637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska resolved KAFKA-3637.
-
Resolution: Won't Fix
> Add method that checks if streams are initialised
> --
[
https://issues.apache.org/jira/browse/KAFKA-3637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15304224#comment-15304224
]
Eno Thereska commented on KAFKA-3637:
-
It turns out it might not make sense to have an
[
https://issues.apache.org/jira/browse/KAFKA-3678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-3678 started by Eno Thereska.
---
> Fix stream integration test timeouts
>
>
>
Eno Thereska created KAFKA-3776:
---
Summary: Unify store and downstream caching in streams
Key: KAFKA-3776
URL: https://issues.apache.org/jira/browse/KAFKA-3776
Project: Kafka
Issue Type: New Fea
Eno Thereska created KAFKA-3777:
---
Summary: Extract the LRU cache out of RocksDBStore
Key: KAFKA-3777
URL: https://issues.apache.org/jira/browse/KAFKA-3777
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-3776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska updated KAFKA-3776:
Reviewer: Eno Thereska
> Unify store and downstream caching in streams
> ---
[
https://issues.apache.org/jira/browse/KAFKA-3777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska updated KAFKA-3777:
Assignee: (was: Guozhang Wang)
> Extract the LRU cache out of RocksDBStore
> ---
[
https://issues.apache.org/jira/browse/KAFKA-3776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska updated KAFKA-3776:
Assignee: (was: Guozhang Wang)
> Unify store and downstream caching in streams
> ---
Eno Thereska created KAFKA-3778:
---
Summary: Change the RocksDB implementation for KStream windowed
aggregations, to not use “range queries” but multiple gets
Key: KAFKA-3778
URL: https://issues.apache.org/jira/browse
Eno Thereska created KAFKA-3779:
---
Summary: Add the LRU cache for KTable.to() operator
Key: KAFKA-3779
URL: https://issues.apache.org/jira/browse/KAFKA-3779
Project: Kafka
Issue Type: Sub-task
Eno Thereska created KAFKA-3780:
---
Summary: Add new config cache.max.bytes.buffering to the streams
configuration
Key: KAFKA-3780
URL: https://issues.apache.org/jira/browse/KAFKA-3780
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-3101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15312133#comment-15312133
]
Eno Thereska commented on KAFKA-3101:
-
[~h...@pinterest.com], [~bbejeck], I just added
[
https://issues.apache.org/jira/browse/KAFKA-3101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska updated KAFKA-3101:
Assignee: (was: Eno Thereska)
> Optimize Aggregation Outputs
>
>
>
[
https://issues.apache.org/jira/browse/KAFKA-3805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15320461#comment-15320461
]
Eno Thereska commented on KAFKA-3805:
-
[~agomez] Could you check if the application id
[
https://issues.apache.org/jira/browse/KAFKA-3805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska reassigned KAFKA-3805:
---
Assignee: Eno Thereska (was: Guozhang Wang)
> Running multiple instances of a Streams app on
[
https://issues.apache.org/jira/browse/KAFKA-3805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15320550#comment-15320550
]
Eno Thereska commented on KAFKA-3805:
-
[~agomez] Ok, your usage makes sense. I'll take
[
https://issues.apache.org/jira/browse/KAFKA-3805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15320770#comment-15320770
]
Eno Thereska commented on KAFKA-3805:
-
[~agomez] The issue seems to be that in StreamT
[
https://issues.apache.org/jira/browse/KAFKA-3805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15322261#comment-15322261
]
Eno Thereska commented on KAFKA-3805:
-
[~agomez] I cannot reproduce problem when using
[
https://issues.apache.org/jira/browse/KAFKA-3805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15322641#comment-15322641
]
Eno Thereska commented on KAFKA-3805:
-
Thanks [~agomez]. If you get a chance, could yo
[
https://issues.apache.org/jira/browse/KAFKA-3805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-3805 started by Eno Thereska.
---
> Running multiple instances of a Streams app on the same machine results in
> Jav
Eno Thereska created KAFKA-3812:
---
Summary: State store locking is incorrect
Key: KAFKA-3812
URL: https://issues.apache.org/jira/browse/KAFKA-3812
Project: Kafka
Issue Type: Bug
Compon
[
https://issues.apache.org/jira/browse/KAFKA-3805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15323059#comment-15323059
]
Eno Thereska commented on KAFKA-3805:
-
[~agomez] I created another JIRA for the case w
[
https://issues.apache.org/jira/browse/KAFKA-3576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15327335#comment-15327335
]
Eno Thereska commented on KAFKA-3576:
-
I understand the goal, but why is the first opt
[
https://issues.apache.org/jira/browse/KAFKA-3858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska updated KAFKA-3858:
Affects Version/s: (was: 0.10.0.0)
0.10.1.0
> Add functions to print stre
[
https://issues.apache.org/jira/browse/KAFKA-3858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska reassigned KAFKA-3858:
---
Assignee: Eno Thereska (was: Guozhang Wang)
> Add functions to print stream topologies
> ---
Eno Thereska created KAFKA-3870:
---
Summary: Remove the window name from Windows class
Key: KAFKA-3870
URL: https://issues.apache.org/jira/browse/KAFKA-3870
Project: Kafka
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/KAFKA-3870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-3870 started by Eno Thereska.
---
> Remove the window name from Windows class
> -
[
https://issues.apache.org/jira/browse/KAFKA-3872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska reassigned KAFKA-3872:
---
Assignee: Eno Thereska (was: Guozhang Wang)
> OOM while running Kafka Streams integration te
[
https://issues.apache.org/jira/browse/KAFKA-3872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-3872 started by Eno Thereska.
---
> OOM while running Kafka Streams integration tests
> -
Eno Thereska created KAFKA-3909:
---
Summary: Queryable state for Kafka Streams
Key: KAFKA-3909
URL: https://issues.apache.org/jira/browse/KAFKA-3909
Project: Kafka
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/KAFKA-3870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska updated KAFKA-3870:
Issue Type: Sub-task (was: Improvement)
Parent: KAFKA-3909
> Remove the window name from Wi
[
https://issues.apache.org/jira/browse/KAFKA-3870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska updated KAFKA-3870:
Summary: Expose state store names to DSL (was: Remove the window name from
Windows class)
> Expose
[
https://issues.apache.org/jira/browse/KAFKA-3870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska updated KAFKA-3870:
Description:
Currently in Kafka Streams the state store names are hidden in the DSL. This
JIRA prop
Eno Thereska created KAFKA-3911:
---
Summary: Enforce KTable materialization
Key: KAFKA-3911
URL: https://issues.apache.org/jira/browse/KAFKA-3911
Project: Kafka
Issue Type: Sub-task
Com
[
https://issues.apache.org/jira/browse/KAFKA-3911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-3911 started by Eno Thereska.
---
> Enforce KTable materialization
> --
>
>
[
https://issues.apache.org/jira/browse/KAFKA-3101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15366124#comment-15366124
]
Eno Thereska commented on KAFKA-3101:
-
[~bbejeck] Sounds great. So the KIP is KIP-63 a
[
https://issues.apache.org/jira/browse/KAFKA-3101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15366230#comment-15366230
]
Eno Thereska commented on KAFKA-3101:
-
Yup. Thanks.
> Optimize Aggregation Outputs
>
[
https://issues.apache.org/jira/browse/KAFKA-3101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367982#comment-15367982
]
Eno Thereska commented on KAFKA-3101:
-
[~bbejeck] Could you provide a bit more context
[
https://issues.apache.org/jira/browse/KAFKA-3911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15369091#comment-15369091
]
Eno Thereska commented on KAFKA-3911:
-
This JIRA needs to be done strictly after KAFKA
[
https://issues.apache.org/jira/browse/KAFKA-3858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-3858 started by Eno Thereska.
---
> Add functions to print stream topologies
> --
[
https://issues.apache.org/jira/browse/KAFKA-3777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska updated KAFKA-3777:
Assignee: Anna Povzner
> Extract the LRU cache out of RocksDBStore
> ---
Eno Thereska created KAFKA-3973:
---
Summary: Investigate feasibility of caching bytes vs. records
Key: KAFKA-3973
URL: https://issues.apache.org/jira/browse/KAFKA-3973
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-3778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska updated KAFKA-3778:
Summary: Avoiding using range queries of RocksDBWindowStore on KStream
windowed aggregations (was:
[
https://issues.apache.org/jira/browse/KAFKA-3777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska updated KAFKA-3777:
Summary: Extract the existing LRU cache out of RocksDBStore (was: Extract
the LRU cache out of Rock
[
https://issues.apache.org/jira/browse/KAFKA-3777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska updated KAFKA-3777:
Description:
The LRU cache that is currently inside the RocksDbStore class. As part of
KAFKA-3776 i
Eno Thereska created KAFKA-3974:
---
Summary: LRU cache should store bytes/object and not records
Key: KAFKA-3974
URL: https://issues.apache.org/jira/browse/KAFKA-3974
Project: Kafka
Issue Type: S
[
https://issues.apache.org/jira/browse/KAFKA-3101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska resolved KAFKA-3101.
-
Resolution: Duplicate
This is a duplicate of KAFKA-3776.
> Optimize Aggregation Outputs
> ---
[
https://issues.apache.org/jira/browse/KAFKA-3101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15383256#comment-15383256
]
Eno Thereska commented on KAFKA-3101:
-
Since this is a duplicate, will resolve.
> Opt
[
https://issues.apache.org/jira/browse/KAFKA-3973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15392234#comment-15392234
]
Eno Thereska commented on KAFKA-3973:
-
[~bbejeck] Thank you for the results. As part o
Eno Thereska created KAFKA-4016:
---
Summary: Kafka Streams join benchmark
Key: KAFKA-4016
URL: https://issues.apache.org/jira/browse/KAFKA-4016
Project: Kafka
Issue Type: Improvement
Co
[
https://issues.apache.org/jira/browse/KAFKA-4016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-4016 started by Eno Thereska.
---
> Kafka Streams join benchmark
>
>
> K
[
https://issues.apache.org/jira/browse/KAFKA-4346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska updated KAFKA-4346:
Labels: newbie (was: )
> Add foreachValue method to KStream
> --
>
[
https://issues.apache.org/jira/browse/KAFKA-4346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska updated KAFKA-4346:
Assignee: (was: Guozhang Wang)
> Add foreachValue method to KStream
> --
[
https://issues.apache.org/jira/browse/KAFKA-4217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska updated KAFKA-4217:
Assignee: (was: Guozhang Wang)
> KStream.transform equivalent of flatMap
> -
[
https://issues.apache.org/jira/browse/KAFKA-4369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska resolved KAFKA-4369.
-
Resolution: Won't Fix
> ZkClient is not closed upon streams shutdown
> ---
[
https://issues.apache.org/jira/browse/KAFKA-4359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-4359 started by Eno Thereska.
---
> Streams integration tests should not use commit interval of 1
> -
[
https://issues.apache.org/jira/browse/KAFKA-4317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska updated KAFKA-4317:
Assignee: (was: Guozhang Wang)
> RocksDB checkpoint files lost on kill -9
>
[
https://issues.apache.org/jira/browse/KAFKA-4273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska updated KAFKA-4273:
Assignee: (was: Guozhang Wang)
> Streams DSL - Add TTL / retention period support for intermedia
[
https://issues.apache.org/jira/browse/KAFKA-4281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska updated KAFKA-4281:
Assignee: (was: Guozhang Wang)
> Should be able to forward aggregation values immediately
>
[
https://issues.apache.org/jira/browse/KAFKA-4240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska updated KAFKA-4240:
Assignee: Guozhang Wang (was: Eno Thereska)
> Remove disableLogging from API
>
[
https://issues.apache.org/jira/browse/KAFKA-4263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska resolved KAFKA-4263.
-
Resolution: Not A Problem
> QueryableStateIntegrationTest.concurrentAccess is failing occasionally
[
https://issues.apache.org/jira/browse/KAFKA-4219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska updated KAFKA-4219:
Assignee: (was: Guozhang Wang)
> Permit setting of event time in stream processor
>
[
https://issues.apache.org/jira/browse/KAFKA-4263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15657015#comment-15657015
]
Eno Thereska commented on KAFKA-4263:
-
Haven't seen this. Closing for now.
> Queryabl
[
https://issues.apache.org/jira/browse/KAFKA-4218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska updated KAFKA-4218:
Assignee: (was: Guozhang Wang)
> Enable access to key in {{ValueTransformer}}
>
[
https://issues.apache.org/jira/browse/KAFKA-4186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15657022#comment-15657022
]
Eno Thereska commented on KAFKA-4186:
-
I haven't seen this happen. Is it still an issu
[
https://issues.apache.org/jira/browse/KAFKA-4182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska updated KAFKA-4182:
Assignee: (was: Guozhang Wang)
> Move the change logger our of RocksDB stores
>
[
https://issues.apache.org/jira/browse/KAFKA-4144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska updated KAFKA-4144:
Assignee: (was: Guozhang Wang)
> Allow per stream/table timestamp extractor
> --
[
https://issues.apache.org/jira/browse/KAFKA-4181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska resolved KAFKA-4181.
-
Resolution: Not A Problem
> Processors punctuate() methods call multiple times
> -
[
https://issues.apache.org/jira/browse/KAFKA-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska updated KAFKA-3739:
Assignee: (was: Liquan Pei)
> Add no-arg constructor for library provided serdes
> -
[
https://issues.apache.org/jira/browse/KAFKA-3705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska updated KAFKA-3705:
Assignee: (was: Liquan Pei)
> Support non-key joining in KTable
> --
[
https://issues.apache.org/jira/browse/KAFKA-3262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15657242#comment-15657242
]
Eno Thereska commented on KAFKA-3262:
-
This is now fixed with KIP-62
> Make KafkaStre
[
https://issues.apache.org/jira/browse/KAFKA-4199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eno Thereska updated KAFKA-4199:
Assignee: (was: Guozhang Wang)
> When a window store segment is dropped we should also clear any
1 - 100 of 488 matches
Mail list logo
