Hi, I am using flink-1.2 streaming API to process clickstream and compute some results per cookie. The computed results are stored in Cassandra using flink-cassandra connector. After a result is stored in cassandra, I want to notify an external system (using their API or via Kafka) that result is available (for one cookie).
Can this be done (with/without modifying sink source code)? What if I create a JointSink that internally uses cassandra sink and kafka sink and writes to both places? I am not worried about same record written multiple times as the computed result and the external system consumption is idempotent. Thank you, Tarandeep
