Search code examples
apache-flinktimescaledb

Flink TimescaleDB Integration


How to integrate Apache Flink with Timescale Db.Explain How integration is done along with some example codes.The problem is Kafka writes into a topic flink reads it and after some calculation it should write in Timescale Db.


Solution

  • You should be able to use Flink's Table API with the JDBC connector with the PostgreSQL driver to write to TimescaleDB. If you get stuck trying to make that work, ask a more specific question, showing what you've tried and explain what's going wrong.