Get the consumer group of the consumer.

Source Config @return properties

Get the event time of the message, which is used for filtering and sorting. @return the event time

Sink Config @return properties

Use the current offset as the starting offset to create a new RocketMQSourceSplit. @return a new RocketMQSourceSplit which uses the current offset as

Returns the index of the target subtask that a specific queue should be assigned to.

Get the size of the message in bytes. @return the message size

Lazy initialize this backend transaction client.

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.

return records container

Resuming message pulling from the message queues. @param messageQueues message queues that need to be resumed.

Seek consumer group previously committed offset @param messageQueue rocketmq queue to locate single queue @return offset for message queue

Seek consumer group previously committed offset @param messageQueue rocketmq queue to locate single queue @return offset for message queue

Seek consumer group previously committed offset @param messageQueue rocketmq queue to locate single queue @return offset for message queue

Seek consumer group previously committed offset @param messageQueue rocketmq queue to locate single queue @return offset for message queue

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

Serializes given element and returns it as a {@link MessageExt}. @param element element to be serialized @param context context to possibly determine

Sets the wanted the {@link DeliveryGuarantee}. @param deliveryGuarantee target delivery guarantee @return {@link RocketMQSinkBuilder}