Hi,
I am getting this exception

Exception in thread "main"
org.apache.kafka.streams.errors.TopologyBuilderException: Invalid topology
building: KTABLE-MAPVALUES-0000000007 and KSTREAM-AGGREGATE-0000000009 are
not joinable

What I am trying to do is I aggregate a KStream into a KTable of type
KTable<String, Map<String, List<V>>>

and I am trying to join it to another KStream which is aggregated into
another KTable of type
 KTable<String, List<V>>

Since keys of both the final KTable are same, I don't understand why it is
giving this exception.

Thanks
Sachin

Reply via email to