Class: TencentCloud::Ckafka::V20190819::KafkaParam

Inherits:

TencentCloud::Common::AbstractModel

Object
TencentCloud::Common::AbstractModel
TencentCloud::Ckafka::V20190819::KafkaParam

show all

Defined in:: lib/v20190819/models.rb

Overview

Ckafka配置

Instance Attribute Summary collapse

#CompressionType ⇒ Object
注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。.
#ConnectorSyncType ⇒ Object
注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。.
#EnableToleration ⇒ Object
注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。.
#KeepPartition ⇒ Object
注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。.
#MsgMultiple ⇒ Object
注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。.
#OffsetType ⇒ Object
注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。.
#PartitionNum ⇒ Object
注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。.
#Prefix ⇒ Object
注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。.
#QpsLimit ⇒ Object
注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。.
#Resource ⇒ Object
注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。.
#ResourceName ⇒ Object
注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。.
#SelfBuilt ⇒ Object
注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。.
#Separator ⇒ Object
注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。.
#StartTime ⇒ Object
注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。.
#TableMappings ⇒ Object
注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。.
#Topic ⇒ Object
注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。.
#TopicId ⇒ Object
注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。.
#TopicRegularExpression ⇒ Object
注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。.
#UseAutoCreateTopic ⇒ Object
注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。.
#UseTableMapping ⇒ Object
注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。.
#ZoneId ⇒ Object
注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。.

Instance Method Summary collapse

Constructor Details

#initialize(selfbuilt = nil, resource = nil, topic = nil, offsettype = nil, starttime = nil, resourcename = nil, zoneid = nil, topicid = nil, partitionnum = nil, enabletoleration = nil, qpslimit = nil, tablemappings = nil, usetablemapping = nil, useautocreatetopic = nil, compressiontype = nil, msgmultiple = nil, connectorsynctype = nil, keeppartition = nil, topicregularexpression = nil, prefix = nil, separator = nil) ⇒ `KafkaParam`

Returns a new instance of KafkaParam.

# File 'lib/v20190819/models.rb', line 8692

def initialize(selfbuilt=nil, resource=nil, topic=nil, offsettype=nil, starttime=nil, resourcename=nil, zoneid=nil, topicid=nil, partitionnum=nil, enabletoleration=nil, qpslimit=nil, tablemappings=nil, usetablemapping=nil, useautocreatetopic=nil, compressiontype=nil, msgmultiple=nil, connectorsynctype=nil, keeppartition=nil, topicregularexpression=nil, prefix=nil, separator=nil)
  @SelfBuilt = selfbuilt
  @Resource = resource
  @Topic = topic
  @OffsetType = offsettype
  @StartTime = starttime
  @ResourceName = resourcename
  @ZoneId = zoneid
  @TopicId = topicid
  @PartitionNum = partitionnum
  @EnableToleration = enabletoleration
  @QpsLimit = qpslimit
  @TableMappings = tablemappings
  @UseTableMapping = usetablemapping
  @UseAutoCreateTopic = useautocreatetopic
  @CompressionType = compressiontype
  @MsgMultiple = msgmultiple
  @ConnectorSyncType = connectorsynctype
  @KeepPartition = keeppartition
  @TopicRegularExpression = topicregularexpression
  @Prefix = prefix
  @Separator = separator
end

Instance Attribute Details

#CompressionType ⇒ `Object`

注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。注意：此字段可能返回 null，表示取不到有效值。

Parameters:

SelfBuilt: —
是否为自建集群
Resource: —
ckafka集群实例Id
Topic: —
主题名，多个以“,”分隔
OffsetType: —
Offset类型，最开始位置earliest，最新位置latest，时间点位置timestamp
StartTime: —
Offset类型为timestamp时必传，传时间戳，精确到秒
ResourceName: —
实例资源名称
ZoneId: —
可用区
TopicId: —
主题Id
PartitionNum: —
Topic的分区数
EnableToleration: —
启用容错实例/开启死信队列
QpsLimit: —
Qps 限制
TableMappings: —
Table到Topic的路由，「分发到多个topic」开关打开时必传
UseTableMapping: —
「分发到多个topic」开关，默认为false
UseAutoCreateTopic: —
使用的Topic是否需要自动创建（目前只支持SOURCE流入任务，如果不使用分发到多个topic，需要在Topic字段填写需要自动创建的topic名）
CompressionType: —
写入Topic时是否进行压缩，不开启填"none"，开启的话，填写"open"。
MsgMultiple: —
源topic消息1条扩增成msgMultiple条写入目标topic(该参数目前只有ckafka流入ckafka适用)
ConnectorSyncType: —
数据同步专用参数, 正常数据处理可为空, 实例级别同步: 仅同步元数据填写"META_SYNC_INSTANCE_TYPE", 同步元数据及全部topic内消息的填写"META_AND_DATA_SYNC_INSTANCE_TYPE"; topic级别同步: 选中的源和目标topic中的消息(需要目标实例也包含该topic)填写"DATA_SYNC_TYPE"
KeepPartition: —
数据同步专用参数, 当通过时,希望下游的消息写入分区与上游的一致,则填true,但下游分区小于上游时,会报错; 不需要一致则为false, 默认为false
TopicRegularExpression: —
正则匹配Topic列表
Prefix: —
Topic 前缀
Separator: —
Topic前缀分隔符



8690
8691
8692

# File 'lib/v20190819/models.rb', line 8690

def CompressionType
  @CompressionType
end

#ConnectorSyncType ⇒ `Object`

Parameters:

SelfBuilt: —
是否为自建集群
Resource: —
ckafka集群实例Id
Topic: —
主题名，多个以“,”分隔
OffsetType: —
Offset类型，最开始位置earliest，最新位置latest，时间点位置timestamp
StartTime: —
Offset类型为timestamp时必传，传时间戳，精确到秒
ResourceName: —
实例资源名称
ZoneId: —
可用区
TopicId: —
主题Id
PartitionNum: —
Topic的分区数
EnableToleration: —
启用容错实例/开启死信队列
QpsLimit: —
Qps 限制
TableMappings: —
Table到Topic的路由，「分发到多个topic」开关打开时必传
UseTableMapping: —
「分发到多个topic」开关，默认为false
UseAutoCreateTopic: —
使用的Topic是否需要自动创建（目前只支持SOURCE流入任务，如果不使用分发到多个topic，需要在Topic字段填写需要自动创建的topic名）
CompressionType: —
写入Topic时是否进行压缩，不开启填"none"，开启的话，填写"open"。
MsgMultiple: —
源topic消息1条扩增成msgMultiple条写入目标topic(该参数目前只有ckafka流入ckafka适用)
ConnectorSyncType: —
数据同步专用参数, 正常数据处理可为空, 实例级别同步: 仅同步元数据填写"META_SYNC_INSTANCE_TYPE", 同步元数据及全部topic内消息的填写"META_AND_DATA_SYNC_INSTANCE_TYPE"; topic级别同步: 选中的源和目标topic中的消息(需要目标实例也包含该topic)填写"DATA_SYNC_TYPE"
KeepPartition: —
数据同步专用参数, 当通过时,希望下游的消息写入分区与上游的一致,则填true,但下游分区小于上游时,会报错; 不需要一致则为false, 默认为false
TopicRegularExpression: —
正则匹配Topic列表
Prefix: —
Topic 前缀
Separator: —
Topic前缀分隔符



8690
8691
8692

# File 'lib/v20190819/models.rb', line 8690

def ConnectorSyncType
  @ConnectorSyncType
end

#EnableToleration ⇒ `Object`

Parameters:

SelfBuilt: —
是否为自建集群
Resource: —
ckafka集群实例Id
Topic: —
主题名，多个以“,”分隔
OffsetType: —
Offset类型，最开始位置earliest，最新位置latest，时间点位置timestamp
StartTime: —
Offset类型为timestamp时必传，传时间戳，精确到秒
ResourceName: —
实例资源名称
ZoneId: —
可用区
TopicId: —
主题Id
PartitionNum: —
Topic的分区数
EnableToleration: —
启用容错实例/开启死信队列
QpsLimit: —
Qps 限制
TableMappings: —
Table到Topic的路由，「分发到多个topic」开关打开时必传
UseTableMapping: —
「分发到多个topic」开关，默认为false
UseAutoCreateTopic: —
使用的Topic是否需要自动创建（目前只支持SOURCE流入任务，如果不使用分发到多个topic，需要在Topic字段填写需要自动创建的topic名）
CompressionType: —
写入Topic时是否进行压缩，不开启填"none"，开启的话，填写"open"。
MsgMultiple: —
源topic消息1条扩增成msgMultiple条写入目标topic(该参数目前只有ckafka流入ckafka适用)
ConnectorSyncType: —
数据同步专用参数, 正常数据处理可为空, 实例级别同步: 仅同步元数据填写"META_SYNC_INSTANCE_TYPE", 同步元数据及全部topic内消息的填写"META_AND_DATA_SYNC_INSTANCE_TYPE"; topic级别同步: 选中的源和目标topic中的消息(需要目标实例也包含该topic)填写"DATA_SYNC_TYPE"
KeepPartition: —
数据同步专用参数, 当通过时,希望下游的消息写入分区与上游的一致,则填true,但下游分区小于上游时,会报错; 不需要一致则为false, 默认为false
TopicRegularExpression: —
正则匹配Topic列表
Prefix: —
Topic 前缀
Separator: —
Topic前缀分隔符



8690
8691
8692

# File 'lib/v20190819/models.rb', line 8690

def EnableToleration
  @EnableToleration
end

#KeepPartition ⇒ `Object`

Parameters:

SelfBuilt: —
是否为自建集群
Resource: —
ckafka集群实例Id
Topic: —
主题名，多个以“,”分隔
OffsetType: —
Offset类型，最开始位置earliest，最新位置latest，时间点位置timestamp
StartTime: —
Offset类型为timestamp时必传，传时间戳，精确到秒
ResourceName: —
实例资源名称
ZoneId: —
可用区
TopicId: —
主题Id
PartitionNum: —
Topic的分区数
EnableToleration: —
启用容错实例/开启死信队列
QpsLimit: —
Qps 限制
TableMappings: —
Table到Topic的路由，「分发到多个topic」开关打开时必传
UseTableMapping: —
「分发到多个topic」开关，默认为false
UseAutoCreateTopic: —
使用的Topic是否需要自动创建（目前只支持SOURCE流入任务，如果不使用分发到多个topic，需要在Topic字段填写需要自动创建的topic名）
CompressionType: —
写入Topic时是否进行压缩，不开启填"none"，开启的话，填写"open"。
MsgMultiple: —
源topic消息1条扩增成msgMultiple条写入目标topic(该参数目前只有ckafka流入ckafka适用)
ConnectorSyncType: —
数据同步专用参数, 正常数据处理可为空, 实例级别同步: 仅同步元数据填写"META_SYNC_INSTANCE_TYPE", 同步元数据及全部topic内消息的填写"META_AND_DATA_SYNC_INSTANCE_TYPE"; topic级别同步: 选中的源和目标topic中的消息(需要目标实例也包含该topic)填写"DATA_SYNC_TYPE"
KeepPartition: —
数据同步专用参数, 当通过时,希望下游的消息写入分区与上游的一致,则填true,但下游分区小于上游时,会报错; 不需要一致则为false, 默认为false
TopicRegularExpression: —
正则匹配Topic列表
Prefix: —
Topic 前缀
Separator: —
Topic前缀分隔符



8690
8691
8692

# File 'lib/v20190819/models.rb', line 8690

def KeepPartition
  @KeepPartition
end

#MsgMultiple ⇒ `Object`

Parameters:

SelfBuilt: —
是否为自建集群
Resource: —
ckafka集群实例Id
Topic: —
主题名，多个以“,”分隔
OffsetType: —
Offset类型，最开始位置earliest，最新位置latest，时间点位置timestamp
StartTime: —
Offset类型为timestamp时必传，传时间戳，精确到秒
ResourceName: —
实例资源名称
ZoneId: —
可用区
TopicId: —
主题Id
PartitionNum: —
Topic的分区数
EnableToleration: —
启用容错实例/开启死信队列
QpsLimit: —
Qps 限制
TableMappings: —
Table到Topic的路由，「分发到多个topic」开关打开时必传
UseTableMapping: —
「分发到多个topic」开关，默认为false
UseAutoCreateTopic: —
使用的Topic是否需要自动创建（目前只支持SOURCE流入任务，如果不使用分发到多个topic，需要在Topic字段填写需要自动创建的topic名）
CompressionType: —
写入Topic时是否进行压缩，不开启填"none"，开启的话，填写"open"。
MsgMultiple: —
源topic消息1条扩增成msgMultiple条写入目标topic(该参数目前只有ckafka流入ckafka适用)
ConnectorSyncType: —
数据同步专用参数, 正常数据处理可为空, 实例级别同步: 仅同步元数据填写"META_SYNC_INSTANCE_TYPE", 同步元数据及全部topic内消息的填写"META_AND_DATA_SYNC_INSTANCE_TYPE"; topic级别同步: 选中的源和目标topic中的消息(需要目标实例也包含该topic)填写"DATA_SYNC_TYPE"
KeepPartition: —
数据同步专用参数, 当通过时,希望下游的消息写入分区与上游的一致,则填true,但下游分区小于上游时,会报错; 不需要一致则为false, 默认为false
TopicRegularExpression: —
正则匹配Topic列表
Prefix: —
Topic 前缀
Separator: —
Topic前缀分隔符



8690
8691
8692

# File 'lib/v20190819/models.rb', line 8690

def MsgMultiple
  @MsgMultiple
end

#OffsetType ⇒ `Object`

Parameters:

SelfBuilt: —
是否为自建集群
Resource: —
ckafka集群实例Id
Topic: —
主题名，多个以“,”分隔
OffsetType: —
Offset类型，最开始位置earliest，最新位置latest，时间点位置timestamp
StartTime: —
Offset类型为timestamp时必传，传时间戳，精确到秒
ResourceName: —
实例资源名称
ZoneId: —
可用区
TopicId: —
主题Id
PartitionNum: —
Topic的分区数
EnableToleration: —
启用容错实例/开启死信队列
QpsLimit: —
Qps 限制
TableMappings: —
Table到Topic的路由，「分发到多个topic」开关打开时必传
UseTableMapping: —
「分发到多个topic」开关，默认为false
UseAutoCreateTopic: —
使用的Topic是否需要自动创建（目前只支持SOURCE流入任务，如果不使用分发到多个topic，需要在Topic字段填写需要自动创建的topic名）
CompressionType: —
写入Topic时是否进行压缩，不开启填"none"，开启的话，填写"open"。
MsgMultiple: —
源topic消息1条扩增成msgMultiple条写入目标topic(该参数目前只有ckafka流入ckafka适用)
ConnectorSyncType: —
数据同步专用参数, 正常数据处理可为空, 实例级别同步: 仅同步元数据填写"META_SYNC_INSTANCE_TYPE", 同步元数据及全部topic内消息的填写"META_AND_DATA_SYNC_INSTANCE_TYPE"; topic级别同步: 选中的源和目标topic中的消息(需要目标实例也包含该topic)填写"DATA_SYNC_TYPE"
KeepPartition: —
数据同步专用参数, 当通过时,希望下游的消息写入分区与上游的一致,则填true,但下游分区小于上游时,会报错; 不需要一致则为false, 默认为false
TopicRegularExpression: —
正则匹配Topic列表
Prefix: —
Topic 前缀
Separator: —
Topic前缀分隔符



8690
8691
8692

# File 'lib/v20190819/models.rb', line 8690

def OffsetType
  @OffsetType
end

#PartitionNum ⇒ `Object`

Parameters:

SelfBuilt: —
是否为自建集群
Resource: —
ckafka集群实例Id
Topic: —
主题名，多个以“,”分隔
OffsetType: —
Offset类型，最开始位置earliest，最新位置latest，时间点位置timestamp
StartTime: —
Offset类型为timestamp时必传，传时间戳，精确到秒
ResourceName: —
实例资源名称
ZoneId: —
可用区
TopicId: —
主题Id
PartitionNum: —
Topic的分区数
EnableToleration: —
启用容错实例/开启死信队列
QpsLimit: —
Qps 限制
TableMappings: —
Table到Topic的路由，「分发到多个topic」开关打开时必传
UseTableMapping: —
「分发到多个topic」开关，默认为false
UseAutoCreateTopic: —
使用的Topic是否需要自动创建（目前只支持SOURCE流入任务，如果不使用分发到多个topic，需要在Topic字段填写需要自动创建的topic名）
CompressionType: —
写入Topic时是否进行压缩，不开启填"none"，开启的话，填写"open"。
MsgMultiple: —
源topic消息1条扩增成msgMultiple条写入目标topic(该参数目前只有ckafka流入ckafka适用)
ConnectorSyncType: —
数据同步专用参数, 正常数据处理可为空, 实例级别同步: 仅同步元数据填写"META_SYNC_INSTANCE_TYPE", 同步元数据及全部topic内消息的填写"META_AND_DATA_SYNC_INSTANCE_TYPE"; topic级别同步: 选中的源和目标topic中的消息(需要目标实例也包含该topic)填写"DATA_SYNC_TYPE"
KeepPartition: —
数据同步专用参数, 当通过时,希望下游的消息写入分区与上游的一致,则填true,但下游分区小于上游时,会报错; 不需要一致则为false, 默认为false
TopicRegularExpression: —
正则匹配Topic列表
Prefix: —
Topic 前缀
Separator: —
Topic前缀分隔符



8690
8691
8692

# File 'lib/v20190819/models.rb', line 8690

def PartitionNum
  @PartitionNum
end

#Prefix ⇒ `Object`

Parameters:

SelfBuilt: —
是否为自建集群
Resource: —
ckafka集群实例Id
Topic: —
主题名，多个以“,”分隔
OffsetType: —
Offset类型，最开始位置earliest，最新位置latest，时间点位置timestamp
StartTime: —
Offset类型为timestamp时必传，传时间戳，精确到秒
ResourceName: —
实例资源名称
ZoneId: —
可用区
TopicId: —
主题Id
PartitionNum: —
Topic的分区数
EnableToleration: —
启用容错实例/开启死信队列
QpsLimit: —
Qps 限制
TableMappings: —
Table到Topic的路由，「分发到多个topic」开关打开时必传
UseTableMapping: —
「分发到多个topic」开关，默认为false
UseAutoCreateTopic: —
使用的Topic是否需要自动创建（目前只支持SOURCE流入任务，如果不使用分发到多个topic，需要在Topic字段填写需要自动创建的topic名）
CompressionType: —
写入Topic时是否进行压缩，不开启填"none"，开启的话，填写"open"。
MsgMultiple: —
源topic消息1条扩增成msgMultiple条写入目标topic(该参数目前只有ckafka流入ckafka适用)
ConnectorSyncType: —
数据同步专用参数, 正常数据处理可为空, 实例级别同步: 仅同步元数据填写"META_SYNC_INSTANCE_TYPE", 同步元数据及全部topic内消息的填写"META_AND_DATA_SYNC_INSTANCE_TYPE"; topic级别同步: 选中的源和目标topic中的消息(需要目标实例也包含该topic)填写"DATA_SYNC_TYPE"
KeepPartition: —
数据同步专用参数, 当通过时,希望下游的消息写入分区与上游的一致,则填true,但下游分区小于上游时,会报错; 不需要一致则为false, 默认为false
TopicRegularExpression: —
正则匹配Topic列表
Prefix: —
Topic 前缀
Separator: —
Topic前缀分隔符



8690
8691
8692

# File 'lib/v20190819/models.rb', line 8690

def Prefix
  @Prefix
end

#QpsLimit ⇒ `Object`

Parameters:

SelfBuilt: —
是否为自建集群
Resource: —
ckafka集群实例Id
Topic: —
主题名，多个以“,”分隔
OffsetType: —
Offset类型，最开始位置earliest，最新位置latest，时间点位置timestamp
StartTime: —
Offset类型为timestamp时必传，传时间戳，精确到秒
ResourceName: —
实例资源名称
ZoneId: —
可用区
TopicId: —
主题Id
PartitionNum: —
Topic的分区数
EnableToleration: —
启用容错实例/开启死信队列
QpsLimit: —
Qps 限制
TableMappings: —
Table到Topic的路由，「分发到多个topic」开关打开时必传
UseTableMapping: —
「分发到多个topic」开关，默认为false
UseAutoCreateTopic: —
使用的Topic是否需要自动创建（目前只支持SOURCE流入任务，如果不使用分发到多个topic，需要在Topic字段填写需要自动创建的topic名）
CompressionType: —
写入Topic时是否进行压缩，不开启填"none"，开启的话，填写"open"。
MsgMultiple: —
源topic消息1条扩增成msgMultiple条写入目标topic(该参数目前只有ckafka流入ckafka适用)
ConnectorSyncType: —
数据同步专用参数, 正常数据处理可为空, 实例级别同步: 仅同步元数据填写"META_SYNC_INSTANCE_TYPE", 同步元数据及全部topic内消息的填写"META_AND_DATA_SYNC_INSTANCE_TYPE"; topic级别同步: 选中的源和目标topic中的消息(需要目标实例也包含该topic)填写"DATA_SYNC_TYPE"
KeepPartition: —
数据同步专用参数, 当通过时,希望下游的消息写入分区与上游的一致,则填true,但下游分区小于上游时,会报错; 不需要一致则为false, 默认为false
TopicRegularExpression: —
正则匹配Topic列表
Prefix: —
Topic 前缀
Separator: —
Topic前缀分隔符



8690
8691
8692

# File 'lib/v20190819/models.rb', line 8690

def QpsLimit
  @QpsLimit
end

#Resource ⇒ `Object`

Parameters:

SelfBuilt: —
是否为自建集群
Resource: —
ckafka集群实例Id
Topic: —
主题名，多个以“,”分隔
OffsetType: —
Offset类型，最开始位置earliest，最新位置latest，时间点位置timestamp
StartTime: —
Offset类型为timestamp时必传，传时间戳，精确到秒
ResourceName: —
实例资源名称
ZoneId: —
可用区
TopicId: —
主题Id
PartitionNum: —
Topic的分区数
EnableToleration: —
启用容错实例/开启死信队列
QpsLimit: —
Qps 限制
TableMappings: —
Table到Topic的路由，「分发到多个topic」开关打开时必传
UseTableMapping: —
「分发到多个topic」开关，默认为false
UseAutoCreateTopic: —
使用的Topic是否需要自动创建（目前只支持SOURCE流入任务，如果不使用分发到多个topic，需要在Topic字段填写需要自动创建的topic名）
CompressionType: —
写入Topic时是否进行压缩，不开启填"none"，开启的话，填写"open"。
MsgMultiple: —
源topic消息1条扩增成msgMultiple条写入目标topic(该参数目前只有ckafka流入ckafka适用)
ConnectorSyncType: —
数据同步专用参数, 正常数据处理可为空, 实例级别同步: 仅同步元数据填写"META_SYNC_INSTANCE_TYPE", 同步元数据及全部topic内消息的填写"META_AND_DATA_SYNC_INSTANCE_TYPE"; topic级别同步: 选中的源和目标topic中的消息(需要目标实例也包含该topic)填写"DATA_SYNC_TYPE"
KeepPartition: —
数据同步专用参数, 当通过时,希望下游的消息写入分区与上游的一致,则填true,但下游分区小于上游时,会报错; 不需要一致则为false, 默认为false
TopicRegularExpression: —
正则匹配Topic列表
Prefix: —
Topic 前缀
Separator: —
Topic前缀分隔符



8690
8691
8692

# File 'lib/v20190819/models.rb', line 8690

def Resource
  @Resource
end

#ResourceName ⇒ `Object`

Parameters:

SelfBuilt: —
是否为自建集群
Resource: —
ckafka集群实例Id
Topic: —
主题名，多个以“,”分隔
OffsetType: —
Offset类型，最开始位置earliest，最新位置latest，时间点位置timestamp
StartTime: —
Offset类型为timestamp时必传，传时间戳，精确到秒
ResourceName: —
实例资源名称
ZoneId: —
可用区
TopicId: —
主题Id
PartitionNum: —
Topic的分区数
EnableToleration: —
启用容错实例/开启死信队列
QpsLimit: —
Qps 限制
TableMappings: —
Table到Topic的路由，「分发到多个topic」开关打开时必传
UseTableMapping: —
「分发到多个topic」开关，默认为false
UseAutoCreateTopic: —
使用的Topic是否需要自动创建（目前只支持SOURCE流入任务，如果不使用分发到多个topic，需要在Topic字段填写需要自动创建的topic名）
CompressionType: —
写入Topic时是否进行压缩，不开启填"none"，开启的话，填写"open"。
MsgMultiple: —
源topic消息1条扩增成msgMultiple条写入目标topic(该参数目前只有ckafka流入ckafka适用)
ConnectorSyncType: —
数据同步专用参数, 正常数据处理可为空, 实例级别同步: 仅同步元数据填写"META_SYNC_INSTANCE_TYPE", 同步元数据及全部topic内消息的填写"META_AND_DATA_SYNC_INSTANCE_TYPE"; topic级别同步: 选中的源和目标topic中的消息(需要目标实例也包含该topic)填写"DATA_SYNC_TYPE"
KeepPartition: —
数据同步专用参数, 当通过时,希望下游的消息写入分区与上游的一致,则填true,但下游分区小于上游时,会报错; 不需要一致则为false, 默认为false
TopicRegularExpression: —
正则匹配Topic列表
Prefix: —
Topic 前缀
Separator: —
Topic前缀分隔符



8690
8691
8692

# File 'lib/v20190819/models.rb', line 8690

def ResourceName
  @ResourceName
end

#SelfBuilt ⇒ `Object`

Parameters:

SelfBuilt: —
是否为自建集群
Resource: —
ckafka集群实例Id
Topic: —
主题名，多个以“,”分隔
OffsetType: —
Offset类型，最开始位置earliest，最新位置latest，时间点位置timestamp
StartTime: —
Offset类型为timestamp时必传，传时间戳，精确到秒
ResourceName: —
实例资源名称
ZoneId: —
可用区
TopicId: —
主题Id
PartitionNum: —
Topic的分区数
EnableToleration: —
启用容错实例/开启死信队列
QpsLimit: —
Qps 限制
TableMappings: —
Table到Topic的路由，「分发到多个topic」开关打开时必传
UseTableMapping: —
「分发到多个topic」开关，默认为false
UseAutoCreateTopic: —
使用的Topic是否需要自动创建（目前只支持SOURCE流入任务，如果不使用分发到多个topic，需要在Topic字段填写需要自动创建的topic名）
CompressionType: —
写入Topic时是否进行压缩，不开启填"none"，开启的话，填写"open"。
MsgMultiple: —
源topic消息1条扩增成msgMultiple条写入目标topic(该参数目前只有ckafka流入ckafka适用)
ConnectorSyncType: —
数据同步专用参数, 正常数据处理可为空, 实例级别同步: 仅同步元数据填写"META_SYNC_INSTANCE_TYPE", 同步元数据及全部topic内消息的填写"META_AND_DATA_SYNC_INSTANCE_TYPE"; topic级别同步: 选中的源和目标topic中的消息(需要目标实例也包含该topic)填写"DATA_SYNC_TYPE"
KeepPartition: —
数据同步专用参数, 当通过时,希望下游的消息写入分区与上游的一致,则填true,但下游分区小于上游时,会报错; 不需要一致则为false, 默认为false
TopicRegularExpression: —
正则匹配Topic列表
Prefix: —
Topic 前缀
Separator: —
Topic前缀分隔符



8690
8691
8692

# File 'lib/v20190819/models.rb', line 8690

def SelfBuilt
  @SelfBuilt
end

#Separator ⇒ `Object`

Parameters:

SelfBuilt: —
是否为自建集群
Resource: —
ckafka集群实例Id
Topic: —
主题名，多个以“,”分隔
OffsetType: —
Offset类型，最开始位置earliest，最新位置latest，时间点位置timestamp
StartTime: —
Offset类型为timestamp时必传，传时间戳，精确到秒
ResourceName: —
实例资源名称
ZoneId: —
可用区
TopicId: —
主题Id
PartitionNum: —
Topic的分区数
EnableToleration: —
启用容错实例/开启死信队列
QpsLimit: —
Qps 限制
TableMappings: —
Table到Topic的路由，「分发到多个topic」开关打开时必传
UseTableMapping: —
「分发到多个topic」开关，默认为false
UseAutoCreateTopic: —
使用的Topic是否需要自动创建（目前只支持SOURCE流入任务，如果不使用分发到多个topic，需要在Topic字段填写需要自动创建的topic名）
CompressionType: —
写入Topic时是否进行压缩，不开启填"none"，开启的话，填写"open"。
MsgMultiple: —
源topic消息1条扩增成msgMultiple条写入目标topic(该参数目前只有ckafka流入ckafka适用)
ConnectorSyncType: —
数据同步专用参数, 正常数据处理可为空, 实例级别同步: 仅同步元数据填写"META_SYNC_INSTANCE_TYPE", 同步元数据及全部topic内消息的填写"META_AND_DATA_SYNC_INSTANCE_TYPE"; topic级别同步: 选中的源和目标topic中的消息(需要目标实例也包含该topic)填写"DATA_SYNC_TYPE"
KeepPartition: —
数据同步专用参数, 当通过时,希望下游的消息写入分区与上游的一致,则填true,但下游分区小于上游时,会报错; 不需要一致则为false, 默认为false
TopicRegularExpression: —
正则匹配Topic列表
Prefix: —
Topic 前缀
Separator: —
Topic前缀分隔符



8690
8691
8692

# File 'lib/v20190819/models.rb', line 8690

def Separator
  @Separator
end

#StartTime ⇒ `Object`

Parameters:

SelfBuilt: —
是否为自建集群
Resource: —
ckafka集群实例Id
Topic: —
主题名，多个以“,”分隔
OffsetType: —
Offset类型，最开始位置earliest，最新位置latest，时间点位置timestamp
StartTime: —
Offset类型为timestamp时必传，传时间戳，精确到秒
ResourceName: —
实例资源名称
ZoneId: —
可用区
TopicId: —
主题Id
PartitionNum: —
Topic的分区数
EnableToleration: —
启用容错实例/开启死信队列
QpsLimit: —
Qps 限制
TableMappings: —
Table到Topic的路由，「分发到多个topic」开关打开时必传
UseTableMapping: —
「分发到多个topic」开关，默认为false
UseAutoCreateTopic: —
使用的Topic是否需要自动创建（目前只支持SOURCE流入任务，如果不使用分发到多个topic，需要在Topic字段填写需要自动创建的topic名）
CompressionType: —
写入Topic时是否进行压缩，不开启填"none"，开启的话，填写"open"。
MsgMultiple: —
源topic消息1条扩增成msgMultiple条写入目标topic(该参数目前只有ckafka流入ckafka适用)
ConnectorSyncType: —
数据同步专用参数, 正常数据处理可为空, 实例级别同步: 仅同步元数据填写"META_SYNC_INSTANCE_TYPE", 同步元数据及全部topic内消息的填写"META_AND_DATA_SYNC_INSTANCE_TYPE"; topic级别同步: 选中的源和目标topic中的消息(需要目标实例也包含该topic)填写"DATA_SYNC_TYPE"
KeepPartition: —
数据同步专用参数, 当通过时,希望下游的消息写入分区与上游的一致,则填true,但下游分区小于上游时,会报错; 不需要一致则为false, 默认为false
TopicRegularExpression: —
正则匹配Topic列表
Prefix: —
Topic 前缀
Separator: —
Topic前缀分隔符



8690
8691
8692

# File 'lib/v20190819/models.rb', line 8690

def StartTime
  @StartTime
end

#TableMappings ⇒ `Object`

Parameters:

SelfBuilt: —
是否为自建集群
Resource: —
ckafka集群实例Id
Topic: —
主题名，多个以“,”分隔
OffsetType: —
Offset类型，最开始位置earliest，最新位置latest，时间点位置timestamp
StartTime: —
Offset类型为timestamp时必传，传时间戳，精确到秒
ResourceName: —
实例资源名称
ZoneId: —
可用区
TopicId: —
主题Id
PartitionNum: —
Topic的分区数
EnableToleration: —
启用容错实例/开启死信队列
QpsLimit: —
Qps 限制
TableMappings: —
Table到Topic的路由，「分发到多个topic」开关打开时必传
UseTableMapping: —
「分发到多个topic」开关，默认为false
UseAutoCreateTopic: —
使用的Topic是否需要自动创建（目前只支持SOURCE流入任务，如果不使用分发到多个topic，需要在Topic字段填写需要自动创建的topic名）
CompressionType: —
写入Topic时是否进行压缩，不开启填"none"，开启的话，填写"open"。
MsgMultiple: —
源topic消息1条扩增成msgMultiple条写入目标topic(该参数目前只有ckafka流入ckafka适用)
ConnectorSyncType: —
数据同步专用参数, 正常数据处理可为空, 实例级别同步: 仅同步元数据填写"META_SYNC_INSTANCE_TYPE", 同步元数据及全部topic内消息的填写"META_AND_DATA_SYNC_INSTANCE_TYPE"; topic级别同步: 选中的源和目标topic中的消息(需要目标实例也包含该topic)填写"DATA_SYNC_TYPE"
KeepPartition: —
数据同步专用参数, 当通过时,希望下游的消息写入分区与上游的一致,则填true,但下游分区小于上游时,会报错; 不需要一致则为false, 默认为false
TopicRegularExpression: —
正则匹配Topic列表
Prefix: —
Topic 前缀
Separator: —
Topic前缀分隔符



8690
8691
8692

# File 'lib/v20190819/models.rb', line 8690

def TableMappings
  @TableMappings
end

#Topic ⇒ `Object`

Parameters:

SelfBuilt: —
是否为自建集群
Resource: —
ckafka集群实例Id
Topic: —
主题名，多个以“,”分隔
OffsetType: —
Offset类型，最开始位置earliest，最新位置latest，时间点位置timestamp
StartTime: —
Offset类型为timestamp时必传，传时间戳，精确到秒
ResourceName: —
实例资源名称
ZoneId: —
可用区
TopicId: —
主题Id
PartitionNum: —
Topic的分区数
EnableToleration: —
启用容错实例/开启死信队列
QpsLimit: —
Qps 限制
TableMappings: —
Table到Topic的路由，「分发到多个topic」开关打开时必传
UseTableMapping: —
「分发到多个topic」开关，默认为false
UseAutoCreateTopic: —
使用的Topic是否需要自动创建（目前只支持SOURCE流入任务，如果不使用分发到多个topic，需要在Topic字段填写需要自动创建的topic名）
CompressionType: —
写入Topic时是否进行压缩，不开启填"none"，开启的话，填写"open"。
MsgMultiple: —
源topic消息1条扩增成msgMultiple条写入目标topic(该参数目前只有ckafka流入ckafka适用)
ConnectorSyncType: —
数据同步专用参数, 正常数据处理可为空, 实例级别同步: 仅同步元数据填写"META_SYNC_INSTANCE_TYPE", 同步元数据及全部topic内消息的填写"META_AND_DATA_SYNC_INSTANCE_TYPE"; topic级别同步: 选中的源和目标topic中的消息(需要目标实例也包含该topic)填写"DATA_SYNC_TYPE"
KeepPartition: —
数据同步专用参数, 当通过时,希望下游的消息写入分区与上游的一致,则填true,但下游分区小于上游时,会报错; 不需要一致则为false, 默认为false
TopicRegularExpression: —
正则匹配Topic列表
Prefix: —
Topic 前缀
Separator: —
Topic前缀分隔符



8690
8691
8692

# File 'lib/v20190819/models.rb', line 8690

def Topic
  @Topic
end

#TopicId ⇒ `Object`

Parameters:

SelfBuilt: —
是否为自建集群
Resource: —
ckafka集群实例Id
Topic: —
主题名，多个以“,”分隔
OffsetType: —
Offset类型，最开始位置earliest，最新位置latest，时间点位置timestamp
StartTime: —
Offset类型为timestamp时必传，传时间戳，精确到秒
ResourceName: —
实例资源名称
ZoneId: —
可用区
TopicId: —
主题Id
PartitionNum: —
Topic的分区数
EnableToleration: —
启用容错实例/开启死信队列
QpsLimit: —
Qps 限制
TableMappings: —
Table到Topic的路由，「分发到多个topic」开关打开时必传
UseTableMapping: —
「分发到多个topic」开关，默认为false
UseAutoCreateTopic: —
使用的Topic是否需要自动创建（目前只支持SOURCE流入任务，如果不使用分发到多个topic，需要在Topic字段填写需要自动创建的topic名）
CompressionType: —
写入Topic时是否进行压缩，不开启填"none"，开启的话，填写"open"。
MsgMultiple: —
源topic消息1条扩增成msgMultiple条写入目标topic(该参数目前只有ckafka流入ckafka适用)
ConnectorSyncType: —
数据同步专用参数, 正常数据处理可为空, 实例级别同步: 仅同步元数据填写"META_SYNC_INSTANCE_TYPE", 同步元数据及全部topic内消息的填写"META_AND_DATA_SYNC_INSTANCE_TYPE"; topic级别同步: 选中的源和目标topic中的消息(需要目标实例也包含该topic)填写"DATA_SYNC_TYPE"
KeepPartition: —
数据同步专用参数, 当通过时,希望下游的消息写入分区与上游的一致,则填true,但下游分区小于上游时,会报错; 不需要一致则为false, 默认为false
TopicRegularExpression: —
正则匹配Topic列表
Prefix: —
Topic 前缀
Separator: —
Topic前缀分隔符



8690
8691
8692

# File 'lib/v20190819/models.rb', line 8690

def TopicId
  @TopicId
end

#TopicRegularExpression ⇒ `Object`

Parameters:

SelfBuilt: —
是否为自建集群
Resource: —
ckafka集群实例Id
Topic: —
主题名，多个以“,”分隔
OffsetType: —
Offset类型，最开始位置earliest，最新位置latest，时间点位置timestamp
StartTime: —
Offset类型为timestamp时必传，传时间戳，精确到秒
ResourceName: —
实例资源名称
ZoneId: —
可用区
TopicId: —
主题Id
PartitionNum: —
Topic的分区数
EnableToleration: —
启用容错实例/开启死信队列
QpsLimit: —
Qps 限制
TableMappings: —
Table到Topic的路由，「分发到多个topic」开关打开时必传
UseTableMapping: —
「分发到多个topic」开关，默认为false
UseAutoCreateTopic: —
使用的Topic是否需要自动创建（目前只支持SOURCE流入任务，如果不使用分发到多个topic，需要在Topic字段填写需要自动创建的topic名）
CompressionType: —
写入Topic时是否进行压缩，不开启填"none"，开启的话，填写"open"。
MsgMultiple: —
源topic消息1条扩增成msgMultiple条写入目标topic(该参数目前只有ckafka流入ckafka适用)
ConnectorSyncType: —
数据同步专用参数, 正常数据处理可为空, 实例级别同步: 仅同步元数据填写"META_SYNC_INSTANCE_TYPE", 同步元数据及全部topic内消息的填写"META_AND_DATA_SYNC_INSTANCE_TYPE"; topic级别同步: 选中的源和目标topic中的消息(需要目标实例也包含该topic)填写"DATA_SYNC_TYPE"
KeepPartition: —
数据同步专用参数, 当通过时,希望下游的消息写入分区与上游的一致,则填true,但下游分区小于上游时,会报错; 不需要一致则为false, 默认为false
TopicRegularExpression: —
正则匹配Topic列表
Prefix: —
Topic 前缀
Separator: —
Topic前缀分隔符



8690
8691
8692

# File 'lib/v20190819/models.rb', line 8690

def TopicRegularExpression
  @TopicRegularExpression
end

#UseAutoCreateTopic ⇒ `Object`

Parameters:

SelfBuilt: —
是否为自建集群
Resource: —
ckafka集群实例Id
Topic: —
主题名，多个以“,”分隔
OffsetType: —
Offset类型，最开始位置earliest，最新位置latest，时间点位置timestamp
StartTime: —
Offset类型为timestamp时必传，传时间戳，精确到秒
ResourceName: —
实例资源名称
ZoneId: —
可用区
TopicId: —
主题Id
PartitionNum: —
Topic的分区数
EnableToleration: —
启用容错实例/开启死信队列
QpsLimit: —
Qps 限制
TableMappings: —
Table到Topic的路由，「分发到多个topic」开关打开时必传
UseTableMapping: —
「分发到多个topic」开关，默认为false
UseAutoCreateTopic: —
使用的Topic是否需要自动创建（目前只支持SOURCE流入任务，如果不使用分发到多个topic，需要在Topic字段填写需要自动创建的topic名）
CompressionType: —
写入Topic时是否进行压缩，不开启填"none"，开启的话，填写"open"。
MsgMultiple: —
源topic消息1条扩增成msgMultiple条写入目标topic(该参数目前只有ckafka流入ckafka适用)
ConnectorSyncType: —
数据同步专用参数, 正常数据处理可为空, 实例级别同步: 仅同步元数据填写"META_SYNC_INSTANCE_TYPE", 同步元数据及全部topic内消息的填写"META_AND_DATA_SYNC_INSTANCE_TYPE"; topic级别同步: 选中的源和目标topic中的消息(需要目标实例也包含该topic)填写"DATA_SYNC_TYPE"
KeepPartition: —
数据同步专用参数, 当通过时,希望下游的消息写入分区与上游的一致,则填true,但下游分区小于上游时,会报错; 不需要一致则为false, 默认为false
TopicRegularExpression: —
正则匹配Topic列表
Prefix: —
Topic 前缀
Separator: —
Topic前缀分隔符



8690
8691
8692

# File 'lib/v20190819/models.rb', line 8690

def UseAutoCreateTopic
  @UseAutoCreateTopic
end

#UseTableMapping ⇒ `Object`

Parameters:

SelfBuilt: —
是否为自建集群
Resource: —
ckafka集群实例Id
Topic: —
主题名，多个以“,”分隔
OffsetType: —
Offset类型，最开始位置earliest，最新位置latest，时间点位置timestamp
StartTime: —
Offset类型为timestamp时必传，传时间戳，精确到秒
ResourceName: —
实例资源名称
ZoneId: —
可用区
TopicId: —
主题Id
PartitionNum: —
Topic的分区数
EnableToleration: —
启用容错实例/开启死信队列
QpsLimit: —
Qps 限制
TableMappings: —
Table到Topic的路由，「分发到多个topic」开关打开时必传
UseTableMapping: —
「分发到多个topic」开关，默认为false
UseAutoCreateTopic: —
使用的Topic是否需要自动创建（目前只支持SOURCE流入任务，如果不使用分发到多个topic，需要在Topic字段填写需要自动创建的topic名）
CompressionType: —
写入Topic时是否进行压缩，不开启填"none"，开启的话，填写"open"。
MsgMultiple: —
源topic消息1条扩增成msgMultiple条写入目标topic(该参数目前只有ckafka流入ckafka适用)
ConnectorSyncType: —
数据同步专用参数, 正常数据处理可为空, 实例级别同步: 仅同步元数据填写"META_SYNC_INSTANCE_TYPE", 同步元数据及全部topic内消息的填写"META_AND_DATA_SYNC_INSTANCE_TYPE"; topic级别同步: 选中的源和目标topic中的消息(需要目标实例也包含该topic)填写"DATA_SYNC_TYPE"
KeepPartition: —
数据同步专用参数, 当通过时,希望下游的消息写入分区与上游的一致,则填true,但下游分区小于上游时,会报错; 不需要一致则为false, 默认为false
TopicRegularExpression: —
正则匹配Topic列表
Prefix: —
Topic 前缀
Separator: —
Topic前缀分隔符



8690
8691
8692

# File 'lib/v20190819/models.rb', line 8690

def UseTableMapping
  @UseTableMapping
end

#ZoneId ⇒ `Object`

Parameters:

SelfBuilt: —
是否为自建集群
Resource: —
ckafka集群实例Id
Topic: —
主题名，多个以“,”分隔
OffsetType: —
Offset类型，最开始位置earliest，最新位置latest，时间点位置timestamp
StartTime: —
Offset类型为timestamp时必传，传时间戳，精确到秒
ResourceName: —
实例资源名称
ZoneId: —
可用区
TopicId: —
主题Id
PartitionNum: —
Topic的分区数
EnableToleration: —
启用容错实例/开启死信队列
QpsLimit: —
Qps 限制
TableMappings: —
Table到Topic的路由，「分发到多个topic」开关打开时必传
UseTableMapping: —
「分发到多个topic」开关，默认为false
UseAutoCreateTopic: —
使用的Topic是否需要自动创建（目前只支持SOURCE流入任务，如果不使用分发到多个topic，需要在Topic字段填写需要自动创建的topic名）
CompressionType: —
写入Topic时是否进行压缩，不开启填"none"，开启的话，填写"open"。
MsgMultiple: —
源topic消息1条扩增成msgMultiple条写入目标topic(该参数目前只有ckafka流入ckafka适用)
ConnectorSyncType: —
数据同步专用参数, 正常数据处理可为空, 实例级别同步: 仅同步元数据填写"META_SYNC_INSTANCE_TYPE", 同步元数据及全部topic内消息的填写"META_AND_DATA_SYNC_INSTANCE_TYPE"; topic级别同步: 选中的源和目标topic中的消息(需要目标实例也包含该topic)填写"DATA_SYNC_TYPE"
KeepPartition: —
数据同步专用参数, 当通过时,希望下游的消息写入分区与上游的一致,则填true,但下游分区小于上游时,会报错; 不需要一致则为false, 默认为false
TopicRegularExpression: —
正则匹配Topic列表
Prefix: —
Topic 前缀
Separator: —
Topic前缀分隔符



8690
8691
8692

# File 'lib/v20190819/models.rb', line 8690

def ZoneId
  @ZoneId
end

Instance Method Details

#deserialize(params) ⇒ `Object`

# File 'lib/v20190819/models.rb', line 8716

def deserialize(params)
  @SelfBuilt = params['SelfBuilt']
  @Resource = params['Resource']
  @Topic = params['Topic']
  @OffsetType = params['OffsetType']
  @StartTime = params['StartTime']
  @ResourceName = params['ResourceName']
  @ZoneId = params['ZoneId']
  @TopicId = params['TopicId']
  @PartitionNum = params['PartitionNum']
  @EnableToleration = params['EnableToleration']
  @QpsLimit = params['QpsLimit']
  unless params['TableMappings'].nil?
    @TableMappings = []
    params['TableMappings'].each do |i|
      tablemapping_tmp = TableMapping.new
      tablemapping_tmp.deserialize(i)
      @TableMappings << tablemapping_tmp
    end
  end
  @UseTableMapping = params['UseTableMapping']
  @UseAutoCreateTopic = params['UseAutoCreateTopic']
  @CompressionType = params['CompressionType']
  @MsgMultiple = params['MsgMultiple']
  @ConnectorSyncType = params['ConnectorSyncType']
  @KeepPartition = params['KeepPartition']
  @TopicRegularExpression = params['TopicRegularExpression']
  @Prefix = params['Prefix']
  @Separator = params['Separator']
end

Class: TencentCloud::Ckafka::V20190819::KafkaParam

Overview

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

Instance Attribute Details

#CompressionType ⇒ Object

#ConnectorSyncType ⇒ Object

#EnableToleration ⇒ Object

#KeepPartition ⇒ Object

#MsgMultiple ⇒ Object

#OffsetType ⇒ Object

#PartitionNum ⇒ Object

#Prefix ⇒ Object

#QpsLimit ⇒ Object

#Resource ⇒ Object

#ResourceName ⇒ Object

#SelfBuilt ⇒ Object

#Separator ⇒ Object

#StartTime ⇒ Object

#TableMappings ⇒ Object

#Topic ⇒ Object

#TopicId ⇒ Object

#TopicRegularExpression ⇒ Object

#UseAutoCreateTopic ⇒ Object

#UseTableMapping ⇒ Object

#ZoneId ⇒ Object

Instance Method Details

#deserialize(params) ⇒ Object

#CompressionType ⇒ `Object`

#ConnectorSyncType ⇒ `Object`

#EnableToleration ⇒ `Object`

#KeepPartition ⇒ `Object`

#MsgMultiple ⇒ `Object`

#OffsetType ⇒ `Object`

#PartitionNum ⇒ `Object`

#Prefix ⇒ `Object`

#QpsLimit ⇒ `Object`

#Resource ⇒ `Object`

#ResourceName ⇒ `Object`

#SelfBuilt ⇒ `Object`

#Separator ⇒ `Object`

#StartTime ⇒ `Object`

#TableMappings ⇒ `Object`

#Topic ⇒ `Object`

#TopicId ⇒ `Object`

#TopicRegularExpression ⇒ `Object`

#UseAutoCreateTopic ⇒ `Object`

#UseTableMapping ⇒ `Object`

#ZoneId ⇒ `Object`

#deserialize(params) ⇒ `Object`