Get an option value from the given config, convert it into a new value instance.

Get the topic that the message belongs to. @return the topic

Add a config option with a not null value. The config key shouldn't be duplicated. @param option Config option instance, contains key & type definiti

Get the ID of the queue that the message is stored in. @return the queue ID

Get the name of the broker that handles the message. @return the broker name

Validate if the config has a existed option.

Get the body of the message. @return the message body

Sends the message to the messaging system and returns a Future for the send operation. @param message the message to be sent @return a Future for the

Starts the inner consumer.

Build the {@link RocketMQSource}. @return a RocketMQSource with the settings made for this builder.

Get the offset of the message within the queue. @return the queue offset

Set an arbitrary property for the RocketMQ source. The valid keys can be found in {@link RocketMQSourceOptions}. <p>Make sure the option could be set

Returns a set of message queues that are assigned to the current consumer. The assignment is typically performed by a message broker and may change dy

Get the keys of the message, which are used for partitioning and indexing. @return the message keys

This method retrieves the current offsets for a collection of {@link MessageQueue}s using a provided {@link MessageQueueOffsetsRetriever}. @param mes

Converts a byte array to a long value. @param bytes array @return the long value

Validate offsets initializer with properties of RocketMQ source. @param properties Properties of RocketMQ source @throws IllegalStateException if val

Fetch message queues of the topic. @param topic topic list @return key is topic, values are message queue collections

Get an option-related config value. We would return the default config value defined in the option if no value existed instead. @param key Config opt

Get the properties of the message, which are set by the producer. @return the message properties

Fetch data for the topics or partitions specified using assign API @return list of message, can be null.

start inner consumer

Get an {@link OffsetsSelector} which initializes the offsets to the committed offsets. An exception will be thrown at runtime if there is no committed

List max offsets for the specified MessageQueues.

Initialization method for the schema. It is called before the actual working methods {@link #deserialize} and thus suitable for one time setup work.

Overrides the fetch offsets that the consumer will use on the next poll. If this method is invoked for the same message queue more than once, the late

Converts a byte array to an int value. @param bytes byte array @return the int value

Average Hashing queue algorithm Refer: org.apache.rocketmq.client.consumer.rebalance.AllocateStrategyByAveragely

Allocates RocketMQ source splits to Flink tasks based on the selected allocation strategy. @param mqAll a collection of all available RocketMQ source

Manually assign a list of message queues to this consumer. This interface does not allow for incremental assignment and will replace the previous assi

Build credentials for client. @param props @return

Build Common Configs. @param props Properties @param client ClientConfig

Return the builder for building {@link RocketMQConfigValidator}.