Ayoub Omari created KAFKA-19096:
---
Summary: Skipped Records in FK join should not be marked as dropped
Key: KAFKA-19096
URL: https://issues.apache.org/jira/browse/KAFKA-19096
Project: Kafka
thread for this KIP.
Best,
Ayoub
Le mer. 6 nov. 2024 à 17:29, Lucas Brutschy
a écrit :
> Hi Ayoub,
>
> I see that there was already a very long discussion thread, I won't
> start nitpicking names here. I think we are ready to move on to a
> vote. The agreed upon solutioins s
ays, I will start a voting thread.
We can always continue discussion in this thread after that :)
Best,
Ayoub
Le ven. 4 oct. 2024, 02:37, Matthias J. Sax a écrit :
> Thanks Ayoub!
>
> (102) let's hear what others think.
>
> (103) Keeping it internal if fine with me. Was jus
oss a better name we can update the KIP then too).
Yes, better than the first suggested name. Reflected in the KIP.
I also added a note about records with null deduplication key.
If no new points are raised in the next few days, I will start a VOTE
thread.
Thanks,
Ayoub
Le mar. 27 août 2024 à
to a single userId. Any duplicate of that record would be received
> by the task which processes this userId.
Let me know what you think.
Thanks,
Ayoub
Le jeu. 22 août 2024 à 21:37, Bill Bejeck a écrit :
> Hi Ayoub,
>
> What's the status of this KIP?
>
> Regards,
>
processors do for periodic work,
we can track the last cleanup time and the current stream time,
if the delta exceeds the deduplication period, we trigger the cleanup.
Best,
Ayoub
Le jeu. 11 juil. 2024 à 01:17, Bill Bejeck a écrit :
> Hi All,
>
> Thanks Ayoub for getting this KIP g
name to have this information in the name
of the api itself it would be good.
Best,
Ayoub
Le jeu. 13 juin 2024 à 09:03, Sebastien Viale
a écrit :
>
> Hi,
>
> 106 :
>
> Thanks for the clarification. Actually, this is not what I expected, but I
> better understand the performanc
However, if we do a per-task deduplication, the user may adapt to his
specific use-case.
Let me know what you think
Ayoub
Le mar. 11 juin 2024 à 20:21, Matthias J. Sax a écrit :
> Thanks Sebastien,
>
> that's a good point. Thanks for raising it. -- I like your proposal.
>
>
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
I suggest).
In the second case, It would be up to the user to choose
any deduplicationInterval that may sufficiently cover all his late data.
What do you think ?
Thanks,
Ayoub
Le mar. 4 juin 2024 à 23:58, Matthias J. Sax a écrit :
> Ayoub,
>
> thanks for resurrecting this KIP.
Hi everyone,
I've just made a (small) change to this KIP about an implementation detail.
Please let me know your thoughts.
Thank you,
Ayoub
Le lun. 20 mai 2024 à 21:13, Ayoub a écrit :
> Hello,
>
> Following a discussion on community slack channel, I would like to revive
>
though the motivation is not quite the same as the initial one, I
updated the KIP rather than creating a new one, as I believe the end goal
is the same.
Thanks,
Ayoub
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
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
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
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
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
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
Hello,
I am interested in contributing to Apache Kafka.
Could you please grant me contributor access ?
JIRA username: ayoubomari
Wiki username: ayoubomari
Github username: AyoubOm
Thank you,
Ayoub
19 matches
Mail list logo
