Flink对接pulsar作为数据源输出的sink应该如何编写?

提问者:帅平 问题分类:大数据
Flink对接pulsar作为数据源输出的sink应该如何编写?
1 个回答
心已打烊
心已打烊
Flink写入pulsar sink的示例代码是:
PulsarSink<String> sink = PulsarSink.builder()
    .setServiceUrl(serviceUrl)
    .setAdminUrl(adminUrl)
    .setTopics("topic1")
    .setSerializationSchema(new SimpleStringSchema())
    .setDeliveryGuarantee(DeliveryGuarantee.AT_LEAST_ONCE)
    .build();
stream.sinkTo(sink);
发布于:1个月前 (04-11) IP属地:四川省
我来回答