Set arbitrary properties for the RocketMQSink and RocketMQ Consumer. The valid keys can be found in {@link RocketMQSinkOptions} and {@link RocketMQOpt

Sets the {@link RocketMQSerializationSchema} that transforms incoming records to {@link org.apache.rocketmq.common.message.MessageExt}s. @param seria

consume from the min offset at every restart with no state

consume from the specific offset. Group offsets is enable while the broker didn't specify offset.

consume from the closest offset

Set a list of topics the RocketMQSource should consume from. All the topics in the list should have existed in the RocketMQ cluster. Otherwise, an exc

Convert a byte array to a boolean. @param b array @return True or false.

Parse a byte array to double. @param bytes byte array @return Return double made from passed bytes.

Presumes float encoded as IEEE 754 floating-point "single format". @param bytes byte array @return Float made from passed byte array.

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

Creates a new RocketMQConfiguration, which holds a copy of the given configuration that can't be altered. @param config The configuration with the or

Creates a new SplitFetcherManager with a single I/O threads. @param elementsQueue The queue that is used to hand over data from the I/O thread (the

SimpleTopicSelector Constructor. @param topicFieldName field name used for selecting topic @param defaultTopicName default field name used for select

Add a split back to the split enumerator. It will only happen when a {@link SourceReader} fails and there are splits assigned to it after the last suc