[
https://issues.apache.org/jira/browse/FLINK-30552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yufan Sheng updated FLINK-30552:
--------------------------------
Description:
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.
was: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.
> 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
> Priority: Major
> 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)
