Yuriy Badalyantc created KAFKA-10576:
Summary: Different behavior of commitSync and commitAsync
Key: KAFKA-10576
URL: https://issues.apache.org/jira/browse/KAFKA-10576
Project: Kafka
> > > 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
> &
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
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 p
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,
closer to the
> 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
of
> out-of-the-box serdes 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
> >
> > O
ate all
> 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 pu
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 Badalya
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
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 B
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!
> &
`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 about KI
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 ValueSerde
, Deserializer
>
>
> 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
; 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 t
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-↘
ion until 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
lass name 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
>
t the existing Serdes class?
>
> 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 solut
hallenge in situations like 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 t
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
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
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
24 matches
Mail list logo