This interface defines a strategy for allocating RocketMQ source splits to Flink tasks.

Builder of {@link RowKeyValueDeserializationSchema}.

Builder of {@link RowDeserializationSchema}.

BytesSerializer is responsible to deserialize field from byte array.

Utility class to for operations related to bytes.

Message contains byte array.

Options for {@link RowKeyValueDeserializationSchema}.

Options for {@link RowDeserializationSchema}.

Dirty data process strategy.

A Forward messageExt deserialization.

InnerProducer is an interface that represents a message producer used for sending messages to a messaging system. @see AutoCloseable

The interface Message ext deserialization scheme. @param <T> the type parameter

An interface that provides necessary information to the {@link OffsetsSelector} to get the initial offsets of the RocketMQ message queues.

This interface defines the methods for obtaining information about a message in RocketMQ.

Metadata of RowData collector.

Source metadata converter interface.

RocketMQ connector metrics.

Config for #{@link StartupMode#GROUP_OFFSETS}.

The enum class for defining the offset verify behavior.

An interface for users to specify the starting / stopping offset of a {@link RocketMQSourceSplit}.

With Punctuated Watermarks To generate watermarks whenever a certain event indicates that a new watermark might be generated, use AssignerWithPunctuat

An interface for the deserialization of records.

The implementation for offsets retriever with a consumer and an admin client.

Tests for {@link RetryUtil}.

A catalog implementation for RocketMQ.

The {@CatalogFactory} implementation of RocketMQ.

{@link ConfigOption}s for {@link RocketMQCatalog}.

Committer implementation for {@link RocketMQSink} <p>The committer is responsible to finalize the RocketMQ transactions by committing them.

RocketMQConfig for Consumer/Producer.

A builder for building the unmodifiable {@link Configuration} instance. Providing the common validate logic for RocketMQ source & sink.

A config validator for building {@link RocketMQConfiguration} in {@link RocketMQConfigBuilder}. It's used for source & sink builder. <p>We would vali

Builder pattern for building {@link RocketMQConfigValidator}.

An unmodifiable {@link Configuration} for RocketMQ. We provide extra methods for building the different RocketMQ client instance.

An interface for the deserialization of RocketMQ records.

A {@link RocketMQDeserializationSchema} implementation which based on the given flink's {@link DeserializationSchema}. We would consume the message as

Defines the dynamic table sink of RocketMQ.

Defines the {@link DynamicTableSinkFactory} implementation to create {@link RocketMQDynamicTableSink}.

Tests for {@link RocketMQDynamicTableSinkFactory}.

Defines the {@link DynamicTableSourceFactory} implementation to create {@link RocketMQScanTableSource}.

Tests for {@link RocketMQDynamicTableSourceFactory}.

Configuration for RocketMQ Client, these config options would be used for both source, sink and table.

The {@link SimpleVersionedSerializer serializer} for {@link RocketMQSourceSplit}.

Test for {@link RocketMQPartitionSplitSerializer}.

The {@link RecordEmitter} implementation for {@link RocketMQSourceReader}.

Test for {@link RocketMQRecordEmitter}.

RocketMQRowDataConverter converts the row data of table to RocketMQ message pattern.

RocketMQRowDataSink helps for writing the converted row data of table to RocketMQ messages.

A row data wrapper class that wraps a {@link RocketMQDeserializationSchema} to deserialize {@link MessageExt}.

Test for {@link RocketMQRowDeserializationSchema}.

Defines the scan table source of RocketMQ.

The serialization schema for how to serialize records into RocketMQ. A serialization schema which defines how to convert a value of type {@code T} to

Wrap the RocketMQ Schema into RocketMQSerializationSchema. We support schema evolution out of box by this implementation.

The RocketMQSink provides at-least-once reliability guarantees when checkpoints are enabled and batchFlushOnCheckpoint(true) is set. Otherwise, the si

Builder to construct {@link RocketMQSink}. @see RocketMQSink for a more detailed explanation of the different guarantees.

This context provides information on the rocketmq record target location. An implementation that would contain all the required context.

The Source implementation of RocketMQ.