kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jose Lopez <joseariaslo...@gmail.com>
Subject ClassCastException when trying to groupBy after suppress
Date Mon, 08 Apr 2019 09:49:07 GMT
Hi all,

My topology is:

stream -> groupByKey -> windowedBy -> count -> suppress -> groupBy ->
aggregate -> toStream

When I *groupBy* after *suppress*, the following exception is thrown:

java.lang.ClassCastException:
org.apache.kafka.streams.kstream.internals.KTableImpl$$Lambda$15/1208825205
cannot be cast to
org.apache.kafka.streams.kstream.internals.KTableProcessorSupplier

It happens because suppress returns a KtableImpl with a
KTableSuppressProcessor. Then groupBy, when
executes enableSendingOldValues(), it casts it to KTableProcessorSupplier,
and therefore the ClassCastException.

Is this a bug? Am I missing something?

Thank you in advance for your help.

Regards,
Jose

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