Hi,
It seems to be an error in documents. `setDeliverGuarantee` is the method
of class `KafkaSinkBuilder`, .
It could be used like this : KafkaSink.builder().setDeliverGuarantee(xxx)
Lars Skjærven 于2021年12月2日周四 19:34写道：
> Hello,
> upgrading to 1.14 I bumped into an issue with the kafka sink
Hi Lars,
Unfortunately, there is at the moment a small bug in our documentation
[1]. You can set the DeliveryGuarantee on the builder object and not
on the serialization schema. Sorry for the inconvenience.
Best,
Fabian
[1] https://github.com/apache/flink/pull/17971
On Thu, Dec 2, 2021 at
Hello,
upgrading to 1.14 I bumped into an issue with the kafka sink builder when
defining delivery guarantee:
value setDeliveryGuarantee is not a member of
org.apache.flink.connector.kafka.sink.KafkaRecordSerializationSchemaBuilder[]
Seems to be working with the default value (i.e. without
