lqjacklee created KAFKA-10145:
---------------------------------
Summary: Enhance to support the multiple join operation
Key: KAFKA-10145
URL: https://issues.apache.org/jira/browse/KAFKA-10145
Project: Kafka
Issue Type: Improvement
Components: streams
Reporter: lqjacklee
Currently It supports the two stream join, and the join's relationship is
clear. However in some case the data comes from multiple source/stream, and
multiple source's relationship is not sure.
For example :
If we are in the case that the end user will visit the website or click the
item he(she) interested. Once event occur, The system will post one event to
Kafka topic. we will calculate the data based on the click stream and the view
stream.
1, Click Event comes from the click stream
2, View Event comes from the view stream
3,
finally we just care about the ClickView Aggregation Domain object.
So once the click event occur , we just update the click event and the
aggregation object, otherwise view event occur, we can update the view event
and aggregation.
The ClickView Aggregation Object will be persistent. Only the ClickView
Aggregation Object be updated by the click event and the view event. The
ClickView Aggregation's method complete() will return true.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)