flink-sql-connector-nsq

connector

  1. source (scan? lookup?)
  2. sink (append? upsert?)
  3. format(json?)
  4. checkpoint