kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Sachin Mittal <sjmit...@gmail.com>
Subject Understanding org.apache.kafka.streams.errors.TopologyBuilderException
Date Sat, 08 Oct 2016 10:00:33 GMT
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.


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