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
