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

Posted to issues@flink.apache.org by "Jason Kania (Jira)" <ji...@apache.org> on 2023/09/23 17:57:00 UTC

[jira] [Created] (FLINK-33136) Flink Pulsar Connector RoundRobinTopicRouter Generates Invalid Error Message

Jason Kania created FLINK-33136:
-----------------------------------

             Summary: Flink Pulsar Connector RoundRobinTopicRouter Generates Invalid Error Message
                 Key: FLINK-33136
                 URL: https://issues.apache.org/jira/browse/FLINK-33136
             Project: Flink
          Issue Type: Bug
          Components: Connectors / Pulsar
    Affects Versions: 1.17.1
            Reporter: Jason Kania


The RoundRobinTopicRouter class generates the runtime error "You should provide topics for routing topic by message key hash." when no partitions are set. This error is a direct copy of the error in the KeyHashTopicRouter but is nonsensical to a RoundRobinTopicRouter since hashing is not involved in route selection.

More importantly however, this error should be detected at deploy time when the PulsarSink is built with the builder since the list of topics is supplied via the setTopics() method of the builder.

Additionally, the wording of the error is not clear in any case and could be improved to something like: "No partition routing topics were provided to allow for topic routing"

 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)