Skip to content
Permalink
Browse files
[hotfix][docs][connector/pulsar] Fix doc typo of setDeliveryGuarantee
  • Loading branch information
deadwind4 authored and MartijnVisser committed May 23, 2022
1 parent 6200128 commit 5ee8fb440294fc43f6e545972f0ac635c9b92968
Showing 2 changed files with 2 additions and 2 deletions.
@@ -355,7 +355,7 @@ PulsarSink<String> sink = PulsarSink.builder()
.setAdminUrl(adminUrl)
.setTopics("topic1")
.setSerializationSchema(PulsarSerializationSchema.flinkSchema(new SimpleStringSchema()))
.setDeliverGuarantee(DeliveryGuarantee.AT_LEAST_ONCE)
.setDeliveryGuarantee(DeliveryGuarantee.AT_LEAST_ONCE)
.build();
stream.sinkTo(sink);
@@ -434,7 +434,7 @@ PulsarSink<String> sink = PulsarSink.builder()
.setAdminUrl(adminUrl)
.setTopics("topic1")
.setSerializationSchema(PulsarSerializationSchema.flinkSchema(new SimpleStringSchema()))
.setDeliverGuarantee(DeliveryGuarantee.AT_LEAST_ONCE)
.setDeliveryGuarantee(DeliveryGuarantee.AT_LEAST_ONCE)
.build();
stream.sinkTo(sink);

0 comments on commit 5ee8fb4

Please sign in to comment.