[jira] [Commented] (KAFKA-14460) In-memory store iterators can return results with null values

[ https://issues.apache.org/jira/browse/KAFKA-14460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17859725#comment-17859725 ] Ayoub Omari commented on KAFKA-14460: - [~ableegoldman] Is this ticket only about Key

[jira] [Assigned] (KAFKA-14460) In-memory store iterators can return results with null values

[ https://issues.apache.org/jira/browse/KAFKA-14460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ayoub Omari reassigned KAFKA-14460: --- Assignee: Ayoub Omari > In-memory store iterators can return results with null values > ---

[jira] [Commented] (KAFKA-14460) In-memory store iterators can return results with null values

[ https://issues.apache.org/jira/browse/KAFKA-14460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17856330#comment-17856330 ] Ayoub Omari commented on KAFKA-14460: - Hi [~Cerchie], can I pick this up ? > In-mem

[jira] [Commented] (KAFKA-16925) stream-table join does not immediately forward expired records on restart

[ https://issues.apache.org/jira/browse/KAFKA-16925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854839#comment-17854839 ] Ayoub Omari commented on KAFKA-16925: - Thanks for these detailed clarifications ! I

[jira] [Commented] (KAFKA-16925) stream-table join does not immediately forward expired records on restart

[ https://issues.apache.org/jira/browse/KAFKA-16925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854483#comment-17854483 ] Ayoub Omari commented on KAFKA-16925: - > Yes, but it's tracked on a per-task basis,

[jira] [Commented] (KAFKA-16925) stream-table join does not immediately forward expired records on restart

[ https://issues.apache.org/jira/browse/KAFKA-16925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17853954#comment-17853954 ] Ayoub Omari commented on KAFKA-16925: - I think what makes `context.currentStreamTime

[jira] [Updated] (KAFKA-16925) stream-table join does not immediately forward expired records on restart

[ https://issues.apache.org/jira/browse/KAFKA-16925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ayoub Omari updated KAFKA-16925: Description: [KIP-923|https://cwiki.apache.org/confluence/display/KAFKA/KIP-923%3A+Add+A+Grace+Per

[jira] [Updated] (KAFKA-16925) stream-table join does not immediately forward expired records on restart

[ https://issues.apache.org/jira/browse/KAFKA-16925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ayoub Omari updated KAFKA-16925: Description: [KIP-923|https://cwiki.apache.org/confluence/display/KAFKA/KIP-923%3A+Add+A+Grace+Per

[jira] [Created] (KAFKA-16925) stream-table join does not immediately forward expired records on restart

Ayoub Omari created KAFKA-16925: --- Summary: stream-table join does not immediately forward expired records on restart Key: KAFKA-16925 URL: https://issues.apache.org/jira/browse/KAFKA-16925 Project: Kafk

[jira] [Commented] (KAFKA-16700) Kafka Streams: possible message loss on KTable-KTable FK Left Join

[ https://issues.apache.org/jira/browse/KAFKA-16700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846363#comment-17846363 ] Ayoub Omari commented on KAFKA-16700: - [~stoeckmk] About KIP-962, it's not about nul

[jira] [Assigned] (KAFKA-10369) Introduce Distinct operation in KStream

[ https://issues.apache.org/jira/browse/KAFKA-10369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ayoub Omari reassigned KAFKA-10369: --- Assignee: Ayoub Omari (was: Ivan Ponomarev) > Introduce Distinct operation in KStream > --

[jira] [Commented] (KAFKA-16700) Kafka Streams: possible message loss on KTable-KTable FK Left Join

[ https://issues.apache.org/jira/browse/KAFKA-16700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17845956#comment-17845956 ] Ayoub Omari commented on KAFKA-16700: - Also, because you are chaining more than one

[jira] [Commented] (KAFKA-16700) Kafka Streams: possible message loss on KTable-KTable FK Left Join

[ https://issues.apache.org/jira/browse/KAFKA-16700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17845950#comment-17845950 ] Ayoub Omari commented on KAFKA-16700: - [~stoeckmk] Did you check if the foreignKey c

[jira] [Comment Edited] (KAFKA-16700) Kafka Streams: possible message loss on KTable-KTable FK Left Join

[ https://issues.apache.org/jira/browse/KAFKA-16700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17845950#comment-17845950 ] Ayoub Omari edited comment on KAFKA-16700 at 5/13/24 2:06 PM:

[jira] [Commented] (KAFKA-4212) Add a key-value store that is a TTL persistent cache

[ https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17845142#comment-17845142 ] Ayoub Omari commented on KAFKA-4212: My company was looking for such feature earlier

[jira] [Commented] (KAFKA-16644) FK join emits duplicate tombstone on left-side delete

[ https://issues.apache.org/jira/browse/KAFKA-16644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17842285#comment-17842285 ] Ayoub Omari commented on KAFKA-16644: - Hi [~mjsax], I think this is the same issue r

[jira] [Commented] (KAFKA-16573) Streams does not specify where a Serde is needed

[ https://issues.apache.org/jira/browse/KAFKA-16573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17839274#comment-17839274 ] Ayoub Omari commented on KAFKA-16573: - Thanks [~mjsax], I am going to work on it in

[jira] [Assigned] (KAFKA-16573) Streams does not specify where a Serde is needed

[ https://issues.apache.org/jira/browse/KAFKA-16573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ayoub Omari reassigned KAFKA-16573: --- Assignee: Ayoub Omari > Streams does not specify where a Serde is needed >

[jira] [Commented] (KAFKA-16573) Streams does not specify where a Serde is needed

[ https://issues.apache.org/jira/browse/KAFKA-16573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17838672#comment-17838672 ] Ayoub Omari commented on KAFKA-16573: - [~ableegoldman] [~mjsax] I looked a bit into

[jira] [Created] (KAFKA-16573) Streams does not specify where a Serde is needed

Ayoub Omari created KAFKA-16573: --- Summary: Streams does not specify where a Serde is needed Key: KAFKA-16573 URL: https://issues.apache.org/jira/browse/KAFKA-16573 Project: Kafka Issue Type: Im

[jira] [Created] (KAFKA-16458) Add contains method in KeyValue store interface

Ayoub Omari created KAFKA-16458: --- Summary: Add contains method in KeyValue store interface Key: KAFKA-16458 URL: https://issues.apache.org/jira/browse/KAFKA-16458 Project: Kafka Issue Type: Wis

[jira] [Updated] (KAFKA-16434) ForeignKey INNER join does not unset join result when FK becomes null

[ https://issues.apache.org/jira/browse/KAFKA-16434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ayoub Omari updated KAFKA-16434: Description: We have two topics : _left-topic[String, LeftRecord]_ and _right-topic[String, Strin

[jira] [Commented] (KAFKA-16434) ForeignKey INNER join does not unset join result when FK becomes null

[ https://issues.apache.org/jira/browse/KAFKA-16434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17831702#comment-17831702 ] Ayoub Omari commented on KAFKA-16434: - I submitted a bug fix for this in the same PR

[jira] [Assigned] (KAFKA-16434) ForeignKey INNER join does not unset join result when FK becomes null

[ https://issues.apache.org/jira/browse/KAFKA-16434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ayoub Omari reassigned KAFKA-16434: --- Assignee: Ayoub Omari > ForeignKey INNER join does not unset join result when FK becomes nu

[jira] [Updated] (KAFKA-16434) ForeignKey INNER join does not unset join result when FK becomes null

[ https://issues.apache.org/jira/browse/KAFKA-16434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ayoub Omari updated KAFKA-16434: External issue URL: (was: https://github.com/apache/kafka/pull/15615) > ForeignKey INNER join do

[jira] [Updated] (KAFKA-16434) ForeignKey INNER join does not unset join result when FK becomes null

[ https://issues.apache.org/jira/browse/KAFKA-16434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ayoub Omari updated KAFKA-16434: External issue URL: https://github.com/apache/kafka/pull/15615 > ForeignKey INNER join does not un

[jira] [Updated] (KAFKA-16407) ForeignKey INNER join ignores FK change when its previous value is null

[ https://issues.apache.org/jira/browse/KAFKA-16407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ayoub Omari updated KAFKA-16407: Affects Version/s: 3.3.2 3.2.3 3.1.2

[jira] [Updated] (KAFKA-16407) ForeignKey INNER join ignores FK change when its previous value is null

[ https://issues.apache.org/jira/browse/KAFKA-16407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ayoub Omari updated KAFKA-16407: Affects Version/s: 3.6.1 3.5.2 3.4.1 > ForeignKey IN

[jira] [Updated] (KAFKA-16434) ForeignKey INNER join does not unset join result when FK becomes null

[ https://issues.apache.org/jira/browse/KAFKA-16434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ayoub Omari updated KAFKA-16434: Description: We have two topics : _left-topic[String, LeftRecord]_ and _right-topic[String, Strin

[jira] [Updated] (KAFKA-16434) ForeignKey INNER join does not unset join result when FK becomes null

[ https://issues.apache.org/jira/browse/KAFKA-16434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ayoub Omari updated KAFKA-16434: Description: We have two topics : _left-topic[String, LeftRecord]_ and _right-topic[String, Strin

[jira] [Created] (KAFKA-16434) ForeignKey INNER join does not unset join result when FK becomes null

Ayoub Omari created KAFKA-16434: --- Summary: ForeignKey INNER join does not unset join result when FK becomes null Key: KAFKA-16434 URL: https://issues.apache.org/jira/browse/KAFKA-16434 Project: Kafka

[jira] [Commented] (KAFKA-16407) ForeignKey INNER join ignores FK change when its previous value is null

[ https://issues.apache.org/jira/browse/KAFKA-16407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17831501#comment-17831501 ] Ayoub Omari commented on KAFKA-16407: - Actually this behavior is not concerned by th

[jira] [Assigned] (KAFKA-16407) ForeignKey INNER join ignores FK change when its previous value is null

[ https://issues.apache.org/jira/browse/KAFKA-16407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ayoub Omari reassigned KAFKA-16407: --- Assignee: Ayoub Omari > ForeignKey INNER join ignores FK change when its previous value is

[jira] [Updated] (KAFKA-16407) ForeignKey INNER join ignores FK change when its previous value is null

[ https://issues.apache.org/jira/browse/KAFKA-16407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ayoub Omari updated KAFKA-16407: Affects Version/s: 3.6.1 3.5.2 3.4.1

[jira] [Created] (KAFKA-16407) ForeignKey INNER join ignores FK change when its previous value is null

Ayoub Omari created KAFKA-16407: --- Summary: ForeignKey INNER join ignores FK change when its previous value is null Key: KAFKA-16407 URL: https://issues.apache.org/jira/browse/KAFKA-16407 Project: Kafka

[jira] [Updated] (KAFKA-16407) ForeignKey INNER join ignores FK change when its previous value is null

[ https://issues.apache.org/jira/browse/KAFKA-16407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ayoub Omari updated KAFKA-16407: Attachment: InnerFKJoinTest.scala JsonSerde.scala > ForeignKey INNER join ignores

[jira] [Updated] (KAFKA-16394) ForeignKey LEFT join propagates null value on foreignKey change

[ https://issues.apache.org/jira/browse/KAFKA-16394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ayoub Omari updated KAFKA-16394: Description: We have two topics : _left-topic[String, LeftRecord]_ and _right-topic[String, Strin

[jira] [Updated] (KAFKA-16394) ForeignKey LEFT join propagates null value on foreignKey change

[ https://issues.apache.org/jira/browse/KAFKA-16394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ayoub Omari updated KAFKA-16394: Description: We have two topics : _left-topic[String, LeftRecord]_ and _right-topic[String, Strin

[jira] [Assigned] (KAFKA-16394) ForeignKey LEFT join propagates null value on foreignKey change

[ https://issues.apache.org/jira/browse/KAFKA-16394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ayoub Omari reassigned KAFKA-16394: --- Assignee: Ayoub Omari > ForeignKey LEFT join propagates null value on foreignKey change > -

[jira] [Created] (KAFKA-16394) ForeignKey LEFT join propagates null value on foreignKey change

Ayoub Omari created KAFKA-16394: --- Summary: ForeignKey LEFT join propagates null value on foreignKey change Key: KAFKA-16394 URL: https://issues.apache.org/jira/browse/KAFKA-16394 Project: Kafka

[jira] [Updated] (KAFKA-16343) Improve tests of streams foreignkeyjoin package

[ https://issues.apache.org/jira/browse/KAFKA-16343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ayoub Omari updated KAFKA-16343: Summary: Improve tests of streams foreignkeyjoin package (was: Improve tests of streams foreignke

[jira] [Updated] (KAFKA-16343) Improve tests of streams foreignkeyjoin package

[ https://issues.apache.org/jira/browse/KAFKA-16343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ayoub Omari updated KAFKA-16343: Description: Some classes are not tested in streams foreignkeyjoin package, such as SubscriptionS

[jira] [Created] (KAFKA-16343) Improve tests of streams foreignkey package

Ayoub Omari created KAFKA-16343: --- Summary: Improve tests of streams foreignkey package Key: KAFKA-16343 URL: https://issues.apache.org/jira/browse/KAFKA-16343 Project: Kafka Issue Type: Improve

[jira] [Assigned] (KAFKA-14747) FK join should record discarded subscription responses

[ https://issues.apache.org/jira/browse/KAFKA-14747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ayoub Omari reassigned KAFKA-14747: --- Assignee: Ayoub Omari (was: Koma Zhang) > FK join should record discarded subscription res

[jira] [Commented] (KAFKA-14747) FK join should record discarded subscription responses

[ https://issues.apache.org/jira/browse/KAFKA-14747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818919#comment-17818919 ] Ayoub Omari commented on KAFKA-14747: - Picking this up since [~kma] didn't respo

[jira] [Commented] (KAFKA-14747) FK join should record discarded subscription responses

[ https://issues.apache.org/jira/browse/KAFKA-14747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815424#comment-17815424 ] Ayoub Omari commented on KAFKA-14747: - I see that the ticket is open for a while. Ma

[jira] [Assigned] (KAFKA-15625) Do not flush global state store at each commit

[ https://issues.apache.org/jira/browse/KAFKA-15625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ayoub Omari reassigned KAFKA-15625: --- Assignee: Ayoub Omari > Do not flush global state store at each commit > --

[jira] [Commented] (KAFKA-15625) Do not flush global state store at each commit

[ https://issues.apache.org/jira/browse/KAFKA-15625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813682#comment-17813682 ] Ayoub Omari commented on KAFKA-15625: - [~cadonna] I am assigning myself to the ticke

[jira] [Commented] (KAFKA-15625) Do not flush global state store at each commit

[ https://issues.apache.org/jira/browse/KAFKA-15625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813099#comment-17813099 ] Ayoub Omari commented on KAFKA-15625: - Hi [~cadonna], is this improvement ready for

[jira] [Updated] (KAFKA-14404) Fix & update docs on client configs controlled by Streams

[ https://issues.apache.org/jira/browse/KAFKA-14404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ayoub Omari updated KAFKA-14404: External issue URL: (was: https://github.com/apache/kafka/pull/15162) > Fix & update docs on cli

[jira] [Updated] (KAFKA-14404) Fix & update docs on client configs controlled by Streams

[ https://issues.apache.org/jira/browse/KAFKA-14404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ayoub Omari updated KAFKA-14404: External issue URL: https://github.com/apache/kafka/pull/15162 > Fix & update docs on client confi

[jira] [Assigned] (KAFKA-14404) Fix & update docs on client configs controlled by Streams

[ https://issues.apache.org/jira/browse/KAFKA-14404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ayoub Omari reassigned KAFKA-14404: --- Assignee: Ayoub Omari (was: Sujay Hegde) > Fix & update docs on client configs controlled

[jira] [Commented] (KAFKA-14404) Fix & update docs on client configs controlled by Streams

[ https://issues.apache.org/jira/browse/KAFKA-14404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17803252#comment-17803252 ] Ayoub Omari commented on KAFKA-14404: - Hi [~ableegoldman] & [~sujayopensource]  I s