src/main/java/org/apache/flink/connector/rocketmq/sink/committer/SendCommittable.java [133:141]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                + topic
                + '\''
                + ", brokerName='"
                + brokerName
                + '\''
                + ", queueId="
                + queueId
                + ", queueOffset="
                + queueOffset
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/org/apache/flink/connector/rocketmq/source/reader/MessageViewExt.java [150:158]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                + topic
                + '\''
                + ", brokerName='"
                + brokerName
                + '\''
                + ", queueId="
                + queueId
                + ", queueOffset="
                + queueOffset
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -