You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "lqjacklee (Jira)" <ji...@apache.org> on 2020/06/11 03:11:00 UTC

[jira] [Created] (KAFKA-10145) Enhance to support the multiple join operation

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)