RocketMQSink

Starter class

rocketmq_sink-sink.jar

com.oceanbase.oms.connector.rocketmq.sink.RocketMQSinkBooster

[Metadata] nameSvrAddr

• Description: specifies the address of RocketMQ.

• Default value: None. This parameter is required.

• Valid values: strings.

• Supported versions: OceanBase Migration Service (OMS) Community Edition V3.3.1 and later.

[Authentication] accessKey

• Description: specifies the AccessKey ID of RocketMQ.

• Default value: None.

• Valid values: strings.

• Supported versions: OMS Community Edition V3.3.1 and later.

[Authentication] secretKey

• Description: specifies the AccessKey secret of RocketMQ.

• Default value: None.

• Valid values: strings.

• Supported versions: OMS Community Edition V3.3.1 and later.

[Metadata] producerGroup

• Description: specifies the producer group of RocketMQ.

• Default value: OMS.

• Valid values: strings.

• Supported versions: OMS Community Edition V3.3.1 and later.

[Message settings] tags

• Description: specifies message tags. If this parameter is specified, messages will be suffixed "_tag".

• Default value: default.

• Valid values: strings.

• Supported versions: OMS Community Edition V3.3.1 and later.

[Distribution] partitionMode

• Description: specifies the distribution logic that determines the partition into which a data record is to be written.

• Default value: HASH.

• Valid values: HASH (hash value of the primary key) and TABLE (hash value of the table name).

• Supported versions: OMS Community Edition V3.3.1 and later.

• [Threads] workerNum

• Description: specifies the number of data writing threads.

• Default value: 4.

• Valid values: integer values.

• Supported versions: OMS Community Edition V3.3.1 and later.

[Error handling] sendMsgTimeout

• Description: specifies timeout period for sending messages.

• Default value: 3000ms.

• Valid values: integer values.

• Supported versions: OMS Community Edition V3.3.1 and later.

[RocketMQ parameters] enableTrace

• Description: specifies whether to enable RocketMQ client traces.

• Default value: false.

• Valid values: Boolean values.

• Supported versions: OMS Community Edition V3.3.1 and later.

[Serialization] serializerType

• Description: specifies the serialization format.

• Default value: DEFAULT.

• Valid values: DEFAULT, DEFAULT_WITH_SCHEMA, SHAREPLEX, CANAL, DATAWORKS_V2, and DATAWORKS_V1.

• Supported versions: OMS Community Edition V3.3.1 and later.

[Time zone conversion] dateTimezone

• Description: specifies the time zone for the time specified by dateTime.

  If the parameter is set to +08:00, the time specified by dateTime is in the UTC+8 time zone.

• Default value: 0.

• Supported versions: OMS Community Edition V4.2.7 and later.

[Time zone conversion] dateConvertTimezone

• Description: specifies the time zone for time conversion.

  If the parameter is set to +08:00, the time specified by dateTime is converted to the UTC+8 time zone.

• Default value: 0.

• Supported versions: OMS Community Edition V4.2.7 and later.

[Time zone conversion] dateConvertFormat

• Description: specifies the time format.

  If the parameter is set to yyyy-MM-dd HH:mm:ss, the time values of datetime and timestamp are output in the specified format.

• Supported versions: OMS Community Edition V4.2.7 and later.