[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=17846363#comment-17846363 ] Ayoub Omari commented on KAFKA-16700: - [~stoeckmk] About KIP-962, it's not about null foreign keys,

[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=17845956#comment-17845956 ] Ayoub Omari commented on KAFKA-16700: - Also, because you are chaining more than one leftJoin, you

[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=17845950#comment-17845950 ] Ayoub Omari commented on KAFKA-16700: - [~stoeckmk] Did you check if the foreignKey column is never

[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=17845950#comment-17845950 ] Ayoub Omari edited comment on KAFKA-16700 at 5/13/24 2:06 PM: -- [~stoeckmk]

[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=17845142#comment-17845142 ] Ayoub Omari commented on KAFKA-4212: My company was looking for such feature earlier this year. For

[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=17842285#comment-17842285 ] Ayoub Omari commented on KAFKA-16644: - Hi [~mjsax], I think this is the same issue reported in 

[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=17839274#comment-17839274 ] Ayoub Omari commented on KAFKA-16573: - Thanks [~mjsax], I am going to work on it in this case. >

[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=17838672#comment-17838672 ] Ayoub Omari commented on KAFKA-16573: - [~ableegoldman] [~mjsax] I looked a bit into this, and found

[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:

[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:

[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,

[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=17831702#comment-17831702 ] Ayoub Omari commented on KAFKA-16434: - I submitted a bug fix for this in the same PR as KAFKA-16407:

[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

[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

[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

[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

[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,

[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,

[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=17831501#comment-17831501 ] Ayoub Omari commented on KAFKA-16407: - Actually this behavior is not concerned by this KIP, it's a

[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,

[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,

[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

[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

[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:

[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

[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=17818919#comment-17818919 ] Ayoub Omari commented on KAFKA-14747: - Picking this up since [~kma] didn't respond :) > FK join

[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=17815424#comment-17815424 ] Ayoub Omari commented on KAFKA-14747: - I see that the ticket is open for a while. May I take it over

[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=17813682#comment-17813682 ] Ayoub Omari commented on KAFKA-15625: - [~cadonna] I am assigning myself to the ticket for now.

[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=17813099#comment-17813099 ] Ayoub Omari commented on KAFKA-15625: - Hi [~cadonna], is this improvement ready for development ? I

[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

[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

[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=17803252#comment-17803252 ] Ayoub Omari commented on KAFKA-14404: - Hi [~ableegoldman] & [~sujayopensource]  I see that this