Get the number of the subtask that RocketMQSink is running on. The numbering starts from 0 and goes up to parallelism-1. (parallelism as returned by {

Gets the consumer group of the consumer. @return the consumer group of the consumer

Get the option value by a prefix. We would return an empty map if the option doesn't exist.

Allocate strategy name @return Current strategy name

Get the tag of the message, which is used for filtering. @return the message tag

Mark partition splits initialized by {@link RocketMQSourceEnumerator#initializeSourceSplits(SourceChangeResult)} as pending and try to assign pending

called every time the user-defined function is initialized, be that when the function is first initialized or be that when the function is actually re

RocketMQ can check the schema and upgrade the schema automatically. If you enable this option, we wouldn't serialize the record into bytes, we send an

Get an {@link OffsetsSelector} which initializes the offsets to the latest offsets of each partition. @return an {@link OffsetsSelector} which initia

Gets the next record from the current split. Returns null if no more records are left in this split.

Moves to the next split. This method is also called initially to move to the first split. Returns null, if no splits are left.

Get an {@link OffsetsSelector} which initializes the offsets to the specified offsets. @param offsets the specified offsets for each partition. @retu

Override the option with the given value. It will not check the existed option comparing to {@link #set(ConfigOption, Object)}.

Returns the current process time in flink.