[jira] [Created] (KAFKA-14949) Add Streams upgrade tests from AK 3.4

Victoria Xia created KAFKA-14949: Summary: Add Streams upgrade tests from AK 3.4 Key: KAFKA-14949 URL: https://issues.apache.org/jira/browse/KAFKA-14949 Project: Kafka Issue Type: Task

[jira] [Commented] (KAFKA-14911) Add system tests for rolling upgrade path of KIP-904

[ https://issues.apache.org/jira/browse/KAFKA-14911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17716134#comment-17716134 ] Victoria Xia commented on KAFKA-14911: -- I can help pick this up, in light of the upcoming 3.5 code

[jira] [Updated] (KAFKA-14834) Improved processor semantics for versioned stores

[ https://issues.apache.org/jira/browse/KAFKA-14834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victoria Xia updated KAFKA-14834: - Description: With the introduction of versioned state stores in

[jira] [Created] (KAFKA-14864) Memory leak in KStreamWindowAggregate with ON_WINDOW_CLOSE emit strategy

Victoria Xia created KAFKA-14864: Summary: Memory leak in KStreamWindowAggregate with ON_WINDOW_CLOSE emit strategy Key: KAFKA-14864 URL: https://issues.apache.org/jira/browse/KAFKA-14864 Project:

[jira] [Created] (KAFKA-14834) Improved stream-table and table-table join semantics for versioned stores

Victoria Xia created KAFKA-14834: Summary: Improved stream-table and table-table join semantics for versioned stores Key: KAFKA-14834 URL: https://issues.apache.org/jira/browse/KAFKA-14834 Project:

[jira] [Updated] (KAFKA-14723) Do not write expired store records to changelog

[ https://issues.apache.org/jira/browse/KAFKA-14723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victoria Xia updated KAFKA-14723: - Description: Window stores and versioned stores both have concepts of "retention" and

[jira] [Created] (KAFKA-14723) Do not write expired store records to changelog

Victoria Xia created KAFKA-14723: Summary: Do not write expired store records to changelog Key: KAFKA-14723 URL: https://issues.apache.org/jira/browse/KAFKA-14723 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-14491) Introduce Versioned Key-Value Stores to Kafka Streams

Victoria Xia created KAFKA-14491: Summary: Introduce Versioned Key-Value Stores to Kafka Streams Key: KAFKA-14491 URL: https://issues.apache.org/jira/browse/KAFKA-14491 Project: Kafka Issue

[jira] [Updated] (KAFKA-13373) ValueTransformerWithKeySupplier doesn't work with store()

[ https://issues.apache.org/jira/browse/KAFKA-13373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victoria Xia updated KAFKA-13373: - Labels: newbie (was: ) > ValueTransformerWithKeySupplier doesn't work with store() >

[jira] [Commented] (KAFKA-13261) KTable to KTable foreign key join loose events when using several partitions

[ https://issues.apache.org/jira/browse/KAFKA-13261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17426245#comment-17426245 ] Victoria Xia commented on KAFKA-13261: -- Hi [~xnix] , of course! It's no trouble at all. Could you

[jira] [Commented] (KAFKA-13268) Add more integration tests for Table Table FK joins with repartitioning

[ https://issues.apache.org/jira/browse/KAFKA-13268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17423390#comment-17423390 ] Victoria Xia commented on KAFKA-13268: -- Hey [~guozhang] we've already got 

[jira] [Commented] (KAFKA-13261) KTable to KTable foreign key join loose events when using several partitions

[ https://issues.apache.org/jira/browse/KAFKA-13261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17423388#comment-17423388 ] Victoria Xia commented on KAFKA-13261: -- Hi [~xnix], KIP-775 for adding interfaces to support custom

[jira] [Comment Edited] (KAFKA-13261) KTable to KTable foreign key join loose events when using several partitions

[ https://issues.apache.org/jira/browse/KAFKA-13261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17416776#comment-17416776 ] Victoria Xia edited comment on KAFKA-13261 at 9/17/21, 11:46 PM: - Hey

[jira] [Commented] (KAFKA-13261) KTable to KTable foreign key join loose events when using several partitions

[ https://issues.apache.org/jira/browse/KAFKA-13261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17416776#comment-17416776 ] Victoria Xia commented on KAFKA-13261: -- Hey [~mjsax] [~guozhang], after opening the KIP above I

[jira] [Comment Edited] (KAFKA-13261) KTable to KTable foreign key join loose events when using several partitions

[ https://issues.apache.org/jira/browse/KAFKA-13261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17415792#comment-17415792 ] Victoria Xia edited comment on KAFKA-13261 at 9/17/21, 3:12 PM: Thanks

[jira] [Commented] (KAFKA-13261) KTable to KTable foreign key join loose events when using several partitions

[ https://issues.apache.org/jira/browse/KAFKA-13261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17415792#comment-17415792 ] Victoria Xia commented on KAFKA-13261: -- Thanks for the confirmation, Matthias and Guozhang! I've

[jira] [Commented] (KAFKA-13261) KTable to KTable foreign key join loose events when using several partitions

[ https://issues.apache.org/jira/browse/KAFKA-13261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17415337#comment-17415337 ] Victoria Xia commented on KAFKA-13261: -- Hey [~vvcephei] [~abellemare] [~guozhang] I had a look at

[jira] [Assigned] (KAFKA-13268) Add more integration tests for Table Table FK joins with repartitioning

[ https://issues.apache.org/jira/browse/KAFKA-13268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victoria Xia reassigned KAFKA-13268: Assignee: Victoria Xia > Add more integration tests for Table Table FK joins with

[jira] [Assigned] (KAFKA-13261) KTable to KTable foreign key join loose events when using several partitions

[ https://issues.apache.org/jira/browse/KAFKA-13261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victoria Xia reassigned KAFKA-13261: Assignee: Victoria Xia > KTable to KTable foreign key join loose events when using

[jira] [Created] (KAFKA-12366) Performance regression in stream-table joins on trunk

Victoria Xia created KAFKA-12366: Summary: Performance regression in stream-table joins on trunk Key: KAFKA-12366 URL: https://issues.apache.org/jira/browse/KAFKA-12366 Project: Kafka Issue

[jira] [Commented] (KAFKA-10008) Symbol not found when running Kafka Streams with RocksDB dependency on MacOS 10.13.6

[ https://issues.apache.org/jira/browse/KAFKA-10008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108848#comment-17108848 ] Victoria Xia commented on KAFKA-10008: -- Ah, thanks for the context. Sounds like the decision then

[jira] [Created] (KAFKA-10008) Symbol not found when running Kafka Streams with RocksDB dependency on MacOS 10.13.6

Victoria Xia created KAFKA-10008: Summary: Symbol not found when running Kafka Streams with RocksDB dependency on MacOS 10.13.6 Key: KAFKA-10008 URL: https://issues.apache.org/jira/browse/KAFKA-10008