kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Sophie Blee-Goldman <sop...@confluent.io>
Subject Re: stream.filter() based on message header
Date Mon, 08 Jul 2019 17:12:33 GMT
Hi Jorg,

The transform/transformValues/process operators are not inherently
stateful. They *can* be stateful if you choose to connect a statestore, but
otherwise they are stateless and in your case, most likely what you want to


On Thu, Jul 4, 2019 at 2:51 AM Jorg Heymans <jheymans@apache.org> wrote:

> Hi,
> I understand that it's currently not possible to access message headers
> from the filter() DSL operation, is there a semantically equivalent
> (stateless) operation that can achieve the same result ? I understand that
> transform(), transformValues() and process() could achieve the same result
> but they are stateful.
> Thanks,
> Jorg

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