Jose, Thanks for reporting this we have created this Jira https://issues.apache.org/jira/browse/KAFKA-8199 for tracking the issue.
-Bill On Mon, Apr 8, 2019 at 5:49 AM Jose Lopez <joseariaslo...@gmail.com> wrote: > 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 >
