Hi Shilpa,
       The easiest way to do this is the make the Rocks DB state queryable.
Then use the Flink queryable state client to access the state you have
created.


Regards
Taher Koitawala

On Tue, Jul 30, 2019, 4:58 PM Shilpa Deshpande <shilpa....@gmail.com> wrote:

> Hello All,
>
> I am new to Apache Flink. In my company we are thinking of using Flink to
> perform transformation of the data. The source of the data is Apache Kafka
> topics. Each message that we receive on Kafka topic, we want to transform
> it and store it on RocksDB. The messages can come out of order. We would
> like to store the transformed output in RocksDB using Flink and retrieve it
> from a Spring Boot application. The reason for Spring Boot Application is
> outbound messaging involves some stitching as well as ordering of the data.
> Is it possible and advisable to read data from RocksDB from Spring Boot
> Application? Spring Boot Application will not change the data. The reason
> we think Flink can help us is because we might be receiving millions of
> messages during the day so want to make sure use a technology that scales
> well. If you have a snippet of code to achieve this, please share it with
> us.
>
> Thank you for your inputs!
>
> Regards,
> Shilpa
>

Reply via email to