Yufan Sheng created FLINK-30689: ----------------------------------- Summary: Use auto produce bytes schema in Pulsar sink Key: FLINK-30689 URL: https://issues.apache.org/jira/browse/FLINK-30689 Project: Flink Issue Type: Improvement Components: Connectors / Pulsar Affects Versions: pulsar-4.0.0 Reporter: Yufan Sheng Fix For: pulsar-4.0.0
Pulsar has a {{Schema.AUTO_PRODUCE_BYTES()}} for sending the byte array messages to broker with extra schema validation. This would be better than directly using {{Schema.BYTES}} which bypass the validation. -- This message was sent by Atlassian Jira (v8.20.10#820010)