Flink-connector-oceanbase使用问题

[李纪祥]

github上给的java 应用实例，数据是固定写死的，想问一下比如source是kafka或者自定义的source该怎么写？

[川粉]

通过 SQL 客户端可以执行 insert into ob_sink select * from kafka_source 这种 sql 来使用。

通过 DataStream 可以使用类似如下代码，稍晚一些我会更新到 github 的文档里面。

KafkaSource<String> kafkaSource = ...;

env.fromSource(kafkaSource, WatermarkStrategy.noWatermarks(), "Kafka Source")
          .sinkTo(new OceanBaseSink(...))

[李纪祥]

好的。

[李纪祥]