Single stream, two sinks

Posted by Gadi Katsovich on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Single-stream-two-sinks-tp33223.html

Hi,

I'm new to flink and am evaluating it to replace our existing streaming application.

The use case I'm working on is reading messages from RabbitMQ queue, applying some transformation and filtering logic and sending it via HTTP to a 3rd party.

A must have requirement of this flow is to to write the data that was sent to an SQL db, for audit and troubleshooting purposes.

I'm currently basing my HTTP solution on a PR with needed adjustments:
https://github.com/apache/flink/pull/5866/files

How can I add an insertion to a DB after a successful HTTP request?

Thank you.