The group id should be the set for {@link RocketMQSource } before invoking this method. Otherwise, an {@code IllegalStateException} will be thrown.

Deserializes the byte message. <p>Can output multiple records through the {@link Collector}. Note that number and size of the produced records should

Deserialize messageExt to type T you want to output. @param messageExt the messageExt @return the t

Create a RocketMQDeserializationSchema by using the flink's {@link DeserializationSchema}. It would consume the rocketmq message as byte array and dec

Returns the strategy for automatically resetting the offset when there is no initial offset in RocketMQ or if the current offset does not exist in Roc

Get the number of times that the message has been attempted to be delivered. @return the delivery attempt count

Get the ingestion time of the message, which is the time that the message was received by the broker. @return the ingestion time

@return number of parallel RocketMQSink tasks.