kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jun Rao <...@confluent.io>
Subject Re: [DISCUSS] KIP-28 - Add a transform client for data processing
Date Tue, 04 Aug 2015 16:17:09 GMT
A few questions/comments.

1. What's streamTime passed to punctuate()? Is that just the current time?
2. Is punctuate() only called if schedule() is called?
3. The way the KeyValueStore is created seems a bit weird. Since this is
part of the internal state managed by KafkaProcessorContext, it seems there
should be an api to create the KeyValueStore from KafkaProcessorContext,
instead of passing context to the constructor of KeyValueStore?

Thanks,

Jun

On Thu, Jul 23, 2015 at 5:59 PM, Guozhang Wang <wangguoz@gmail.com> wrote:

> Hi all,
>
> I just posted KIP-28: Add a transform client for data processing
> <
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-28+-+Add+a+transform+client+for+data+processing
> >
> .
>
> The wiki page does not yet have the full design / implementation details,
> and this email is to kick-off the conversation on whether we should add
> this new client with the described motivations, and if yes what features /
> functionalities should be included.
>
> Looking forward to your feedback!
>
> -- Guozhang
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message