Flink讀取Kafka數據Sink到MySQL和HBase數據庫

Flink將流數據Sink到數據庫,一般需要自己自定義Sink的實現。下面示例,演示Sink到MySQL和HBase示例。 import java.util.Properties import org.apache.flink.api.common.serialization.SimpleStringSchema import org.apache.flink.streaming.api.scal
相關文章
相關標籤/搜索