Hi Kirti,
Kafka Sink supports sending messages with headers.
You should implement a HeaderProvider to extract headers from input element.
KafkaSink<String> sink = KafkaSink.<String>builder()
.setBootstrapServers(brokers)
.setRecordSerializer(KafkaRecordSerializationSchema.builder()
.setTopic("topic-name")
.setValueSerializationSchema(new SimpleStringSchema())
.setHeaderProvider(new HeaderProvider<String>() {
@Override
public Headers getHeaders(String input) {
//TODO: implements it
return null;
}
})
.build()
)
.build();
Best,
Jiabao
On 2024/02/01 07:46:38 Kirti Dhar Upadhyay K via user wrote:
> Hi Mates,
>
> I have below queries regarding Flink Kafka Sink.
>
>
> 1. Does Kafka Sink support schema registry? If yes, is there any
> documentations to configure the same?
> 2. Does Kafka Sink support sending messages (ProducerRecord) with headers?
>
>
> Regards,
> Kirti Dhar
>
>
