[DISCUSS] KIP-962 Relax non-null key requirement in Kafka Streams

https://cwiki.apache.org/confluence/display/KAFKA/KIP-962%3A+Relax+non-null+key+requirement+in+Kafka+Streams

Re: [DISCUSS] KIP-962 Relax non-null key requirement in Kafka Streams

e two scenarios, > > > and also document that if users apply ValueJoiner only, they may not > > > have this benefit, and hence we suggest users to use the former. > > > > > > > > > Guozhang > > > > > > On Mon, Jul 31, 2023 at 12:11 PM Florin Akermann > > > wrote: > > >> > > >> > https://cwiki.apache.org/confluence/display/KAFKA/KIP-962%3A+Relax+non-null+key+requirement+in+Kafka+Streams >

Re: [DISCUSS] KIP-962 Relax non-null key requirement in Kafka Streams

KIP. > > I would also suggest to include an update to > https://kafka.apache.org/documentation/streams/upgrade-guide > > Cheers, > Lucas > > On Mon, Aug 7, 2023 at 10:51 AM Florin Akermann > wrote: > > > > Hi Both, > > > > Thanks. > > I ad

Re: [DISCUSS] KIP-962 Relax non-null key requirement in Kafka Streams

of repartitioning or should it only be relaxed in the context of left stream-table and left/outer stream-stream joins? Florin On Mon, 7 Aug 2023 at 13:23, Florin Akermann wrote: > Hi Lucas, > > Thanks. I added the point about the upgrade guide as well. > > Florin > > On Mon

Re: [DISCUSS] KIP-962 Relax non-null key requirement in Kafka Streams

ver it in the KIP in > detail. In general, for aggregations we can still apply the > optimization, however, we need to be careful as we could also have two > downstream operators with a shared repartition topic: for this case, we > can only drop upstream if all downstream operator woul

Re: [DISCUSS] KIP-962 Relax non-null key requirement in Kafka Streams

upcoming 3.6 release? > > If there is no more other comments, I think you can start a VOTE thread. > > > -Matthias > > On 8/10/23 4:22 AM, Florin Akermann wrote: > > Thank you for the feedback. > > > >> Not sure if this is the right phrasing? > > >

[VOTE] KIP-962 Relax non-null key requirement in Kafka Streams

https://cwiki.apache.org/confluence/display/KAFKA/KIP-962%3A+Relax+non-null+key+requirement+in+Kafka+Streams

Re: [VOTE] KIP-962 Relax non-null key requirement in Kafka Streams

gt; > > > On Fri, Aug 11, 2023 at 1:08 AM Matthias J. Sax > wrote: > > > > > > +1 (binding) > > > > > > On 8/10/23 12:31 PM, Florin Akermann wrote: > > > > > > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-962%3A+Relax+non-null+key+requirement+in+Kafka+Streams > > > > > > >

KIP-962: Review of second Jira/PR before 3.7 release

Hi, As part of KIP-962 https://github.com/apache/kafka/pull/14174 got merged. I think it would be good to tackle the related jira in the same release (3.7) https://issues.apache.org/jira/browse/KAFKA-14748 https://github.com/apache/kafka/pull/14107 Thanks, Florin

Re: [DISCUSS] KIP-837 Allow MultiCasting a Result Record.

Hi Sagar, Thanks for the KIP. I am wondering about the following. What about other classes than the org.apache.kafka.streams.processor.internals.RecordCollectorImpl. Would they still call .partition(...) and just crash? Or is it a given that they never receive a reference to a Partitioner of type

Contributer List

Hi, I would like to become a contributor. My Jira account username is 'aki' Thank you in advance. Florin

[DISCUSS] KIP-798 Add possibility to write kafka headers in Kafka Console Producer

https://cwiki.apache.org/confluence/display/KAFKA/KIP-798%3A+Add+possibility+to+write+kafka+headers+in+Kafka+Console+Producer

Re: [VOTE] KIP-798 Add possibility to write kafka headers in Kafka Console Producer

Hi John, Thanks for the vote and feedback. The thought occurred to me too. Do I understand it correctly: the current version of the kafka-console-producer cannot be used for anything other than UTF-8 keys and values? (There is no other implementation of MessageReader other than the ConsoleProduc

Re: [VOTE] KIP-798 Add possibility to write kafka headers in Kafka Console Producer

and of course if you have other > thoughts, > > please also add them into KIP. > > > > Also, in the "public interface" section, there are 3 "Default parsing > > pattern", I think you should add 1 remaining case (false, false) to make > it > >

Re: [VOTE] KIP-798 Add possibility to write kafka headers in Kafka Console Producer

be `parse.headers`. > > Best, > David > > On Mon, Nov 22, 2021 at 6:20 PM Bill Bejeck wrote: > > > > Hi Florin, > > > > Thanks for the KIP, this seems like a very useful addition. > > > > +1(binding). > > > > -Bill > > > &

Re: [VOTE] KIP-798 Add possibility to write kafka headers in Kafka Console Producer

gt; > Thank you. > Luke > > On Tue, Nov 23, 2021 at 2:00 AM Florin Akermann > > wrote: > > > Hi Bill and David, > > > > Thank you both for the vote. > > @David: KIP is updated. > > > > Florin > > > > On Mon, 22 Nov 2021 at 18:28,

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

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

[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

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