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)

Reply via email to