[jira] [Comment Edited] (KAFKA-12317) Relax non-null key requirement for left/outer KStream joins

[ https://issues.apache.org/jira/browse/KAFKA-12317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17835506#comment-17835506 ] Florin Akermann edited comment on KAFKA-12317 at 4/9/24 6:50 PM: -

[jira] [Commented] (KAFKA-12317) Relax non-null key requirement for left/outer KStream joins

[ https://issues.apache.org/jira/browse/KAFKA-12317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17835506#comment-17835506 ] Florin Akermann commented on KAFKA-12317: - [~mjsax]  https://github.com/apache/k

[jira] [Commented] (KAFKA-12317) Relax non-null key requirement for left/outer KStream joins

[ https://issues.apache.org/jira/browse/KAFKA-12317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818138#comment-17818138 ] Florin Akermann commented on KAFKA-12317: - Thanks for the flag! > Would you be

[jira] [Comment Edited] (KAFKA-14049) Relax Non Null Requirement for KStreamGlobalKTable Left Join

[ https://issues.apache.org/jira/browse/KAFKA-14049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818136#comment-17818136 ] Florin Akermann edited comment on KAFKA-14049 at 2/17/24 9:14 AM:

[jira] [Comment Edited] (KAFKA-14049) Relax Non Null Requirement for KStreamGlobalKTable Left Join

[ https://issues.apache.org/jira/browse/KAFKA-14049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818136#comment-17818136 ] Florin Akermann edited comment on KAFKA-14049 at 2/17/24 9:14 AM:

[jira] [Comment Edited] (KAFKA-14049) Relax Non Null Requirement for KStreamGlobalKTable Left Join

[ https://issues.apache.org/jira/browse/KAFKA-14049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818136#comment-17818136 ] Florin Akermann edited comment on KAFKA-14049 at 2/17/24 9:13 AM:

[jira] [Resolved] (KAFKA-14049) Relax Non Null Requirement for KStreamGlobalKTable Left Join

[ https://issues.apache.org/jira/browse/KAFKA-14049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florin Akermann resolved KAFKA-14049. - Resolution: Fixed > Relax Non Null Requirement for KStreamGlobalKTable Left Join > -

[jira] [Commented] (KAFKA-14049) Relax Non Null Requirement for KStreamGlobalKTable Left Join

[ https://issues.apache.org/jira/browse/KAFKA-14049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818136#comment-17818136 ] Florin Akermann commented on KAFKA-14049: - [~mjsax]  Yes. The following behavio

[jira] (KAFKA-16123) KStreamKStreamJoinProcessor does not drop late records.

[ https://issues.apache.org/jira/browse/KAFKA-16123 ] Florin Akermann deleted comment on KAFKA-16123: - was (Author: aki): I now committed a 'generalized fix' proposal > KStreamKStreamJoinProcessor does not drop late records. > -

[jira] (KAFKA-16123) KStreamKStreamJoinProcessor does not drop late records.

[ https://issues.apache.org/jira/browse/KAFKA-16123 ] Florin Akermann deleted comment on KAFKA-16123: - was (Author: aki): This might actually be a general issue and not just for null-key records? In other words, the problem already existed p

[jira] [Updated] (KAFKA-16123) KStreamKStreamJoinProcessor does not drop late records.

[ https://issues.apache.org/jira/browse/KAFKA-16123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florin Akermann updated KAFKA-16123: Description: Issue illustration: [https://github.com/apache/kafka/pull/15314/files] Sugges

[jira] [Updated] (KAFKA-16123) KStreamKStreamJoinProcessor does not drop late records.

[ https://issues.apache.org/jira/browse/KAFKA-16123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florin Akermann updated KAFKA-16123: Description: Issue illustration: [https://github.com/apache/kafka/pull/15314/files] (was:

[jira] [Updated] (KAFKA-16123) KStreamKStreamJoinProcessor does not drop late records.

[ https://issues.apache.org/jira/browse/KAFKA-16123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florin Akermann updated KAFKA-16123: Summary: KStreamKStreamJoinProcessor does not drop late records. (was: KStreamKStreamJoin

[jira] [Updated] (KAFKA-16123) KStreamKStreamJoinProcessor forwards null-key records for left/outer joins unconditionally of the join window.

[ https://issues.apache.org/jira/browse/KAFKA-16123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florin Akermann updated KAFKA-16123: Description: As part of KIP-962 the non-null key requirements have been relaxed for left a

[jira] [Comment Edited] (KAFKA-16123) KStreamKStreamJoinProcessor forwards null-key records for left/outer joins unconditionally of the join window.

[ https://issues.apache.org/jira/browse/KAFKA-16123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17816355#comment-17816355 ] Florin Akermann edited comment on KAFKA-16123 at 2/10/24 10:18 PM: ---

[jira] [Commented] (KAFKA-16123) KStreamKStreamJoinProcessor forwards null-key records for left/outer joins unconditionally of the join window.

[ https://issues.apache.org/jira/browse/KAFKA-16123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17816355#comment-17816355 ] Florin Akermann commented on KAFKA-16123: - I now committed a 'generalized fix' 

[jira] [Comment Edited] (KAFKA-16123) KStreamKStreamJoinProcessor forwards null-key records for left/outer joins unconditionally of the join window.

[ https://issues.apache.org/jira/browse/KAFKA-16123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814001#comment-17814001 ] Florin Akermann edited comment on KAFKA-16123 at 2/10/24 10:46 AM: ---

[jira] [Comment Edited] (KAFKA-16123) KStreamKStreamJoinProcessor forwards null-key records for left/outer joins unconditionally of the join window.

[ https://issues.apache.org/jira/browse/KAFKA-16123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814001#comment-17814001 ] Florin Akermann edited comment on KAFKA-16123 at 2/10/24 10:45 AM: ---

[jira] [Comment Edited] (KAFKA-16123) KStreamKStreamJoinProcessor forwards null-key records for left/outer joins unconditionally of the join window.

[ https://issues.apache.org/jira/browse/KAFKA-16123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814001#comment-17814001 ] Florin Akermann edited comment on KAFKA-16123 at 2/10/24 10:46 AM: ---

[jira] [Comment Edited] (KAFKA-16123) KStreamKStreamJoinProcessor forwards null-key records for left/outer joins unconditionally of the join window.

[ https://issues.apache.org/jira/browse/KAFKA-16123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814001#comment-17814001 ] Florin Akermann edited comment on KAFKA-16123 at 2/3/24 11:21 PM:

[jira] [Updated] (KAFKA-16123) KStreamKStreamJoinProcessor forwards null-key records for left/outer joins unconditionally of the join window.

[ https://issues.apache.org/jira/browse/KAFKA-16123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florin Akermann updated KAFKA-16123: Summary: KStreamKStreamJoinProcessor forwards null-key records for left/outer joins uncond

[jira] [Comment Edited] (KAFKA-16123) KStreamKStreamJoinProcessor forwards null records for left/outer joins unconditionally of the join window.

[ https://issues.apache.org/jira/browse/KAFKA-16123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814001#comment-17814001 ] Florin Akermann edited comment on KAFKA-16123 at 2/3/24 11:19 PM:

[jira] [Comment Edited] (KAFKA-16123) KStreamKStreamJoinProcessor forwards null records for left/outer joins unconditionally of the join window.

[ https://issues.apache.org/jira/browse/KAFKA-16123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814001#comment-17814001 ] Florin Akermann edited comment on KAFKA-16123 at 2/3/24 11:19 PM:

[jira] [Comment Edited] (KAFKA-16123) KStreamKStreamJoinProcessor forwards null records for left/outer joins unconditionally of the join window.

[ https://issues.apache.org/jira/browse/KAFKA-16123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814001#comment-17814001 ] Florin Akermann edited comment on KAFKA-16123 at 2/3/24 11:18 PM:

[jira] [Updated] (KAFKA-16123) KStreamKStreamJoinProcessor forwards null records for left/outer joins unconditionally of the join window.

[ https://issues.apache.org/jira/browse/KAFKA-16123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florin Akermann updated KAFKA-16123: Description: As part of KIP-962 the non-null key requirements have been relaxed for left a

[jira] [Commented] (KAFKA-16123) KStreamKStreamJoinProcessor forwards null records for left/outer joins unconditionally of the join window.

[ https://issues.apache.org/jira/browse/KAFKA-16123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814001#comment-17814001 ] Florin Akermann commented on KAFKA-16123: - This might actually be a general issu

[jira] [Updated] (KAFKA-16123) KStreamKStreamJoinProcessor forwards null records for left/outer joins unconditionally of the join window.

[ https://issues.apache.org/jira/browse/KAFKA-16123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florin Akermann updated KAFKA-16123: Description: As part of KIP-962 the non-null key requirements have been relaxed for left a

[jira] [Created] (KAFKA-16123) KStreamKStreamJoinProcessor forwards null records for left/outer joins unconditionally of the join window.

Florin Akermann created KAFKA-16123: --- Summary: KStreamKStreamJoinProcessor forwards null records for left/outer joins unconditionally of the join window. Key: KAFKA-16123 URL: https://issues.apache.org/jira/brow

[jira] [Resolved] (KAFKA-12317) Relax non-null key requirement for left/outer KStream joins

[ https://issues.apache.org/jira/browse/KAFKA-12317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florin Akermann resolved KAFKA-12317. - Resolution: Fixed > Relax non-null key requirement for left/outer KStream joins > --

[jira] [Resolved] (KAFKA-14748) Relax non-null FK left-join requirement

[ https://issues.apache.org/jira/browse/KAFKA-14748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florin Akermann resolved KAFKA-14748. - Resolution: Fixed > Relax non-null FK left-join requirement > --

[jira] [Comment Edited] (KAFKA-14748) Relax non-null FK left-join requirement

[ https://issues.apache.org/jira/browse/KAFKA-14748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746242#comment-17746242 ] Florin Akermann edited comment on KAFKA-14748 at 8/13/23 10:49 AM: ---

[jira] [Comment Edited] (KAFKA-12317) Relax non-null key requirement for left/outer KStream joins

[ https://issues.apache.org/jira/browse/KAFKA-12317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746244#comment-17746244 ] Florin Akermann edited comment on KAFKA-12317 at 8/13/23 10:48 AM: ---

[jira] [Commented] (KAFKA-13197) KStream-GlobalKTable join semantics don't match documentation

[ https://issues.apache.org/jira/browse/KAFKA-13197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17753349#comment-17753349 ] Florin Akermann commented on KAFKA-13197: - [~twbecker], thanks for raising this.

[jira] [Commented] (KAFKA-14049) Relax Non Null Requirement for KStreamGlobalKTable Left Join

[ https://issues.apache.org/jira/browse/KAFKA-14049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17752738#comment-17752738 ] Florin Akermann commented on KAFKA-14049: - Same for me. I simply assigned it to

[jira] [Commented] (KAFKA-12317) Relax non-null key requirement for left/outer KStream joins

[ https://issues.apache.org/jira/browse/KAFKA-12317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17752407#comment-17752407 ] Florin Akermann commented on KAFKA-12317: - Drafted a PR: [https://github.com/apa

[jira] [Commented] (KAFKA-12317) Relax non-null key requirement for left/outer KStream joins

[ https://issues.apache.org/jira/browse/KAFKA-12317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17749322#comment-17749322 ] Florin Akermann commented on KAFKA-12317: - [~guozhang] [~mjsax]  KIP: https://c

[jira] [Commented] (KAFKA-14748) Relax non-null FK left-join requirement

[ https://issues.apache.org/jira/browse/KAFKA-14748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17749325#comment-17749325 ] Florin Akermann commented on KAFKA-14748: - Thank you [~guozhang]. Here is the KI

[jira] [Comment Edited] (KAFKA-14748) Relax non-null FK left-join requirement

[ https://issues.apache.org/jira/browse/KAFKA-14748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747670#comment-17747670 ] Florin Akermann edited comment on KAFKA-14748 at 7/29/23 12:55 PM: ---

[jira] [Comment Edited] (KAFKA-14748) Relax non-null FK left-join requirement

[ https://issues.apache.org/jira/browse/KAFKA-14748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747670#comment-17747670 ] Florin Akermann edited comment on KAFKA-14748 at 7/26/23 9:54 PM:

[jira] [Commented] (KAFKA-12317) Relax non-null key requirement for left/outer KStream joins

[ https://issues.apache.org/jira/browse/KAFKA-12317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747671#comment-17747671 ] Florin Akermann commented on KAFKA-12317: - Thanks [~mjsax], I have assigned mys

[jira] [Commented] (KAFKA-14748) Relax non-null FK left-join requirement

[ https://issues.apache.org/jira/browse/KAFKA-14748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747670#comment-17747670 ] Florin Akermann commented on KAFKA-14748: - I have created a PR for this particul

[jira] [Commented] (KAFKA-14049) Relax Non Null Requirement for KStreamGlobalKTable Left Join

[ https://issues.apache.org/jira/browse/KAFKA-14049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747259#comment-17747259 ] Florin Akermann commented on KAFKA-14049: - Hi, [~pnee]  I work on https://issue

[jira] [Assigned] (KAFKA-14049) Relax Non Null Requirement for KStreamGlobalKTable Left Join

[ https://issues.apache.org/jira/browse/KAFKA-14049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florin Akermann reassigned KAFKA-14049: --- Assignee: Florin Akermann (was: Philip Nee) > Relax Non Null Requirement for KStre

[jira] [Assigned] (KAFKA-13197) KStream-GlobalKTable join semantics don't match documentation

[ https://issues.apache.org/jira/browse/KAFKA-13197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florin Akermann reassigned KAFKA-13197: --- Assignee: Florin Akermann > KStream-GlobalKTable join semantics don't match documen

[jira] [Comment Edited] (KAFKA-12317) Relax non-null key requirement for left/outer KStream joins

[ https://issues.apache.org/jira/browse/KAFKA-12317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746244#comment-17746244 ] Florin Akermann edited comment on KAFKA-12317 at 7/24/23 7:38 AM:

[jira] [Comment Edited] (KAFKA-14748) Relax non-null FK left-join requirement

[ https://issues.apache.org/jira/browse/KAFKA-14748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746242#comment-17746242 ] Florin Akermann edited comment on KAFKA-14748 at 7/24/23 7:37 AM:

[jira] [Comment Edited] (KAFKA-14748) Relax non-null FK left-join requirement

[ https://issues.apache.org/jira/browse/KAFKA-14748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746242#comment-17746242 ] Florin Akermann edited comment on KAFKA-14748 at 7/24/23 7:37 AM:

[jira] [Commented] (KAFKA-14748) Relax non-null FK left-join requirement

[ https://issues.apache.org/jira/browse/KAFKA-14748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746242#comment-17746242 ] Florin Akermann commented on KAFKA-14748: - Hi, I will have a go a this if ok. If

[jira] [Assigned] (KAFKA-12317) Relax non-null key requirement for left/outer KStream joins

[ https://issues.apache.org/jira/browse/KAFKA-12317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florin Akermann reassigned KAFKA-12317: --- Assignee: Florin Akermann > Relax non-null key requirement for left/outer KStream j

[jira] [Assigned] (KAFKA-14748) Relax non-null FK left-join requirement

[ https://issues.apache.org/jira/browse/KAFKA-14748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florin Akermann reassigned KAFKA-14748: --- Assignee: Florin Akermann > Relax non-null FK left-join requirement > -

[jira] [Commented] (KAFKA-12317) Relax non-null key requirement for left/outer KStream joins

[ https://issues.apache.org/jira/browse/KAFKA-12317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746244#comment-17746244 ] Florin Akermann commented on KAFKA-12317: - Hi, I will have a go a this if ok. If

[jira] [Commented] (KAFKA-13602) Allow to broadcast a result record

[ https://issues.apache.org/jira/browse/KAFKA-13602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17558760#comment-17558760 ] Florin Akermann commented on KAFKA-13602: - Ok cool, thanks for the quick reply.

[jira] [Commented] (KAFKA-13602) Allow to broadcast a result record

[ https://issues.apache.org/jira/browse/KAFKA-13602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17558751#comment-17558751 ] Florin Akermann commented on KAFKA-13602: - Hi [~sagarrao] , [~mjsax]  May I hav

[jira] [Assigned] (KAFKA-13602) Allow to broadcast a result record

[ https://issues.apache.org/jira/browse/KAFKA-13602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florin Akermann reassigned KAFKA-13602: --- Assignee: (was: Florin Akermann) > Allow to broadcast a result record > ---

[jira] [Assigned] (KAFKA-13602) Allow to broadcast a result record

[ https://issues.apache.org/jira/browse/KAFKA-13602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florin Akermann reassigned KAFKA-13602: --- Assignee: Florin Akermann > Allow to broadcast a result record > --

[jira] [Commented] (KAFKA-13351) Add possibility to write kafka headers in Kafka Console Producer

[ https://issues.apache.org/jira/browse/KAFKA-13351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17442917#comment-17442917 ] Florin Akermann commented on KAFKA-13351: - [~habdank] I created a kip and starte

[jira] [Commented] (KAFKA-13351) Add possibility to write kafka headers in Kafka Console Producer

[ https://issues.apache.org/jira/browse/KAFKA-13351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17436525#comment-17436525 ] Florin Akermann commented on KAFKA-13351: - Hi, I made a PR for it. However I can

[jira] [Commented] (KAFKA-13351) Add possibility to write kafka headers in Kafka Console Producer

[ https://issues.apache.org/jira/browse/KAFKA-13351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17436205#comment-17436205 ] Florin Akermann commented on KAFKA-13351: - Hi, I would like to pick this up. >