[FLINK-24490] The sample code is wrong in Apache Kafka Connector page

• Type: Bug
• Status: In Progress
• Priority: Minor
• Resolution: Unresolved
• Affects Version/s: 1.14.0
• Fix Version/s: 1.14.0
• Component/s: Documentation
• Labels: pull-request-available stale-assigned
• Assignee: JasonLee
• Reporter: JasonLee
• Created: 09/Oct/21 04:43
• Updated: 27/May/22 15:57

Description

There is a sample code error in the kafka sink part

// code placeholder
KafkaSink<String> sink = KafkaSink.<String>builder()
        .setBootstrapServers(brokers)
        .setRecordSerializer(KafkaRecordSerializationSchema.builder()
            .setTopic("topic-name")
            .setValueSerializationSchema(new SimpleStringSchema())
            .setDeliveryGuarantee(DeliveryGuarantee.AT_LEAST_ONCE)
            .build()
        )
        .build();

The correct wording should be as follows

// code placeholder
KafkaSink<String> sink = KafkaSink.<String>builder()                                                                                                
       .setBootstrapServers(brokers)                   
       .setRecordSerializer(KafkaRecordSerializationSchema.builder() 
             .setTopic("topic-name")
             .setValueSerializationSchema(new SimpleStringSchema()) 
             .build() 
        )
        .setDeliverGuarantee(DeliveryGuarantee.AT_LEAST_ONCE)
        .build();

Issue Links

• links to: GitHub Pull Request #19837