You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Yufan Sheng (Jira)" <ji...@apache.org> on 2023/01/03 12:14:00 UTC

[jira] [Created] (FLINK-30552) Pulsar connector shouldn't assert the BatchMessageId size.

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)