全部面试刷题微服务数据库消息队列搜索引擎大数据运维 go语言机器学习

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

提问者：帅平问题分类：大数据

Flink Pulsar

发布于：5个月前 (04-11) IP属地：四川省

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);

发布于：5个月前 (04-11) IP属地：四川省

我来回答