Calculate new split assignment according allocate strategy

Get the unique message ID. @return the message ID

only flink job start with no state can init offsets from broker @param messageQueues @throws MQClientException

List min offsets for the specified MessageQueues.

Initialization method for the schema. It is called before the actual working methods {@link #serialize(Object, RocketMQSinkContext, Long)} and thus su

Suspending message pulling from the message queues. @param messageQueues message queues that need to be suspended.

Configure the access point with which the SDK should communicate. @param endpoints address of service. @return the client configuration builder insta

Sets the consumer group id of the RocketMQSource. @param groupId the group id of the RocketMQSource. @return this RocketMQSourceBuilder.

consume from the group offsets those was stored in brokers.

consume from the max offset of each broker's queue at every restart with no state

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

Build Consumer Configs. @param props Properties @param consumer DefaultLitePullConsumer

Build Producer Configs. @param props Properties @param producer DefaultMQProducer

Create a {@link RocketMQSinkBuilder} to construct a new {@link RocketMQSink}. @param <IN> type of incoming records @return {@link RocketMQSinkBuilder

Get a RocketMQSourceBuilder to build a {@link RocketMQSourceBuilder}. @return a RocketMQ source builder.

Commits the send operation identified by the specified SendCommittable object. @param sendCommittable the SendCommittable object identifying the send

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

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

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

Wraps a {@link DeserializationSchema} as the value deserialization schema. The other fields such as key, headers, timestamp are ignored. @param deser