Yufan Sheng created FLINK-30552:
-----------------------------------
Summary: Pulsar connector shouldn't assert the BatchMessageId size.
Key: FLINK-30552
URL: https://issues.apache.org/jira/browse/FLINK-30552
Project: Flink
Issue Type: Bug
Components: Connectors / Pulsar
Affects Versions: pulsar-4.0.0
Reporter: Yufan Sheng
Fix For: pulsar-4.0.0
Pulsar will try to assert the batch message id size in {{MessageIdUtils}}, but
the batch size is determined by the producer in batch mode. So we can promise
the size could be 1. And the next message id calculation should be calculated
by using BatchMessageId.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
