Re: [VOTE] KIP-616: Rename implicit Serdes instances in kafka-streams-scala

2020-08-18 Thread Yuriy Badalyantc
> > > Hi Yuriy, > > > > > > What a coincidence! I was just about to bump this thread myself. It > > would be really nice to get some more votes to push this over the line. > > > > > > Thanks for your patience! > > > > > > -John > &

Re: [VOTE] KIP-616: Rename implicit Serdes instances in kafka-streams-scala

2020-08-13 Thread Yuriy Badalyantc
en immediately delete the message. > > Instaclustr values your privacy. Our privacy policy can be found at > https://www.instaclustr.com/company/policies/privacy-policy > > > On Mon, 10 Aug 2020 at 13:01, Yuriy Badalyantc wrote: > > > Hi everybody. > > > > Just

Re: [VOTE] KIP-616: Rename implicit Serdes instances in kafka-streams-scala

2020-08-09 Thread Yuriy Badalyantc
Hi everybody. Just bumping this thread. This is a pretty minor change only for the Scala API and it's pending in the voting state for a while. -Yuriy On Fri, Aug 7, 2020 at 8:10 AM Yuriy Badalyantc wrote: > Hi everybody. > > There was some minor change since the voting proces

Re: [VOTE] KIP-616: Rename implicit Serdes instances in kafka-streams-scala

2020-08-06 Thread Yuriy Badalyantc
Hi everybody. There was some minor change since the voting process started (nullSerde added). Let's continue to vote. -Yuriy. On Thu, Jul 9, 2020 at 10:00 PM John Roesler wrote: > Thanks Yuriy, > > I'm +1 (binding) > > -John > > On Wed, Jul 8, 2020, at 23:08, Yuriy Bad

Re: [DISCUSS] KIP-616: Rename implicit Serdes instances in kafka-streams-scala

2020-08-05 Thread Yuriy Badalyantc
> Scala type Null. > > I guess Scala users would benefit from both a NullSerde and a UnitSerde, > but not a VoidSerde. > > Thanks for bringing it up, Matthias. > > -John > > On Fri, Jul 10, 2020, at 21:49, Yuriy Badalyantc wrote: > > Ok, I mentioned adding missing

Re: [DISCUSS] KIP-616: Rename implicit Serdes instances in kafka-streams-scala

2020-07-10 Thread Yuriy Badalyantc
erdes and add missing Serdes that are offered in Java to > Scala. > > > -Matthias > > On 7/10/20 7:51 AM, Yuriy Badalyantc wrote: > > Oh, ok. I have done that. Just didn't know that it was necessary. > > > > -Yuriy > > > > On Fri, Jul 10, 2020 at 9:30

Re: [DISCUSS] KIP-616: Rename implicit Serdes instances in kafka-streams-scala

2020-07-10 Thread Yuriy Badalyantc
t; the contents of the new API? > > Thanks, > John > > On Fri, Jul 10, 2020, at 04:54, Yuriy Badalyantc wrote: > > Hi, Matthias, > > > > It's not directly mentioned in the KIP, but I added all missing Java > > serdes. I mentioned it in the pull request desc

Re: [DISCUSS] KIP-616: Rename implicit Serdes instances in kafka-streams-scala

2020-07-10 Thread Yuriy Badalyantc
on the Apache Kafka Committers page. > > > > If people are slow to vote, feel free to keep bumping the thread, just > like with the discussion. > > > > Thanks again for getting involved! > > -John > > > > On Tue, Jul 7, 2020, at 01:51, Yuriy Badalyantc w

[VOTE] KIP-616: Rename implicit Serdes instances in kafka-streams-scala

2020-07-08 Thread Yuriy Badalyantc
Hi everybody I would like to start a vote for KIP-616: https://cwiki.apache.org/confluence/display/KAFKA/KIP-616%3A+Rename+implicit+Serdes+instances+in+kafka-streams-scala This KIP fixes name clash in the org.apache.kafka.streams.scala.Serdes. -Yuriy

Re: [DISCUSS] KIP-616: Rename implicit Serdes instances in kafka-streams-scala

2020-07-07 Thread Yuriy Badalyantc
So, what's next? It's my first KIP and I'm not familiar with all processes. -Yuriy On Mon, Jul 6, 2020 at 1:32 AM John Roesler wrote: > Hi Yuriy, > > Thanks for the update! It looks good to me. > > Thanks, > John > > On Sun, Jul 5, 2020, at 03:27, Yuriy Badalyantc wrote

Re: [DISCUSS] KIP-616: Rename implicit Serdes instances in kafka-streams-scala

2020-07-05 Thread Yuriy Badalyantc
looks the way I expected. > > I just read over the KIP document again. I think it needs to be updated to > the current proposal, and then we’ll be able to start the vote. > > Thanks, > John > > On Tue, Jun 30, 2020, at 04:58, Yuriy Badalyantc wrote: > > Hi everybody! > &

Re: [DISCUSS] KIP-616: Rename implicit Serdes instances in kafka-streams-scala

2020-06-30 Thread Yuriy Badalyantc
`org.apache.kafka.streams.scala.serialization.Serdes` object without name clash. An old one was marked as deprecated. This change is backward compatible and it could be merged in any further release. On Wed, Jun 3, 2020 at 12:41 PM Yuriy Badalyantc wrote: > Hi, John > > Thanks for pointing that out. I expressed my thoughts abou

Re: [DISCUSS] KIP-513: Distinguish between Key and Value serdes in scala wrapper library for kafka streams

2020-06-18 Thread Yuriy Badalyantc
Hi everybody, I just want to ping this discussion. Any thoughts? - Yuriy On Fri, Jun 5, 2020 at 10:22 AM Yuriy Badalyantc wrote: > Hi Matthias, > > I think you misunderstood my diagram. I wanted to show the next > relationships: > - Serde is KeySerde and ValueSer

Re: [DISCUSS] KIP-513: Distinguish between Key and Value serdes in scala wrapper library for kafka streams

2020-06-04 Thread Yuriy Badalyantc
izer > > > Atm, a Serde is just a "container" for serializers and desrialzier though. > > > -Matthias > > > > On 6/2/20 10:40 PM, Yuriy Badalyantc wrote: > > Hi. > > > > I'm the author of the KIP-616. I got acquainted with the KIP-513 and

Re: [DISCUSS] KIP-616: Rename implicit Serdes instances in kafka-streams-scala

2020-06-02 Thread Yuriy Badalyantc
; overlap we should consider here, or if they are just orthogonal. > > Thanks, > -John > > On Thu, May 28, 2020, at 21:36, Yuriy Badalyantc wrote: > > At the current moment, I think John's plan is better than the original > plan > > described in the KIP. I think

Re: [DISCUSS] KIP-513: Distinguish between Key and Value serdes in scala wrapper library for kafka streams

2020-06-02 Thread Yuriy Badalyantc
Hi. I'm the author of the KIP-616. I got acquainted with the KIP-513 and I think overall it's a good idea. But I think workaround only on the scala side is not enough. We could consider moving a bit further and change serde hierarchy on the java side to something like this: KeySerializer-↘

Re: [DISCUSS] KIP-616: Rename implicit Serdes instances in kafka-streams-scala

2020-05-28 Thread Yuriy Badalyantc
ntil we > got > > > it hashed out. > > > > > > I'm glad you prefer Serde*s*, since having multiple different classes > with > > > the same name leads to all kinds of trouble. "Serdes" seems relatively > > > safe because people in the Sca

Re: [DISCUSS] KIP-616: Rename implicit Serdes instances in kafka-streams-scala

2020-05-28 Thread Yuriy Badalyantc
in KIP-478. I wound up creating a > new package for the new Processor. > > Thanks, > John > > On Wed, May 27, 2020, at 22:20, Yuriy Badalyantc wrote: > > Hi John, > > > > I'm stick with the `org.apache.kafka.streams.scala.Serdes` because it's > > sort of convent

Re: [DISCUSS] KIP-616: Rename implicit Serdes instances in kafka-streams-scala

2020-05-27 Thread Yuriy Badalyantc
gt; Thanks, > -John > > On Tue, May 19, 2020, at 01:18, Yuriy Badalyantc wrote: > > Hi John, > > > > Your suggestion looks interesting. I think it's technically doable. But > I'm > > not sure that this is the better solution. I will try to explain. From > the >

Re: [DISCUSS] KIP-616: Rename implicit Serdes instances in kafka-streams-scala

2020-05-19 Thread Yuriy Badalyantc
ke this, so I might just throw out ImplicitSerdes > as an option. > > Do you think this would work? > > Thanks again, > John > > On Mon, May 18, 2020, at 23:35, Yuriy Badalyantc wrote: > > Hi, > > > > I would like to propose KIP-616 to fix naming clash in the kafk

[jira] [Created] (KAFKA-10020) KIP-616: Rename implicit Serdes instances in kafka-streams-scala

2020-05-18 Thread Yuriy Badalyantc (Jira)
Yuriy Badalyantc created KAFKA-10020: Summary: KIP-616: Rename implicit Serdes instances in kafka-streams-scala Key: KAFKA-10020 URL: https://issues.apache.org/jira/browse/KAFKA-10020 Project

[DISCUSS] KIP-616: Rename implicit Serdes instances in kafka-streams-scala

2020-05-18 Thread Yuriy Badalyantc
Hi, I would like to propose KIP-616 to fix naming clash in the kafka streams scala API: https://cwiki.apache.org/confluence/display/KAFKA/KIP-616%3A+Rename+implicit+Serdes+instances+in+kafka-streams-scala Looking forward to your feedback. -Yuriy

[jira] [Created] (KAFKA-10009) Add method for getting last record offset in kafka partition

2020-05-16 Thread Yuriy Badalyantc (Jira)
Yuriy Badalyantc created KAFKA-10009: Summary: Add method for getting last record offset in kafka partition Key: KAFKA-10009 URL: https://issues.apache.org/jira/browse/KAFKA-10009 Project: Kafka