Class: TencentCloud::Ckafka::V20190819::TopicParam

Inherits:
TencentCloud::Common::AbstractModel
  • Object
show all
Defined in:
lib/v20190819/models.rb

Overview

Topic配置

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(resource = nil, offsettype = nil, starttime = nil, topicid = nil, compressiontype = nil, useautocreatetopic = nil, msgmultiple = nil) ⇒ TopicParam

Returns a new instance of TopicParam.



12052
12053
12054
12055
12056
12057
12058
12059
12060
# File 'lib/v20190819/models.rb', line 12052

def initialize(resource=nil, offsettype=nil, starttime=nil, topicid=nil, compressiontype=nil, useautocreatetopic=nil, msgmultiple=nil)
  @Resource = resource
  @OffsetType = offsettype
  @StartTime = starttime
  @TopicId = topicid
  @CompressionType = compressiontype
  @UseAutoCreateTopic = useautocreatetopic
  @MsgMultiple = msgmultiple
end

Instance Attribute Details

#CompressionTypeObject

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

Parameters:

  • Resource:

    单独售卖Topic的Topic名称

  • OffsetType:

    Offset类型,最开始位置earliest,最新位置latest,时间点位置timestamp

  • StartTime:

    Offset类型为timestamp时必传,传时间戳,精确到秒

  • TopicId:

    Topic的TopicId【出参】

  • CompressionType:

    写入Topic时是否进行压缩,不开启填"none",开启的话,可选择"gzip", "snappy", "lz4"中的一个进行填写。

  • UseAutoCreateTopic:

    使用的Topic是否需要自动创建(目前只支持SOURCE流入任务)

  • MsgMultiple:

    源topic消息1条扩增成msgMultiple条写入目标topic(该参数目前只有ckafka流入ckafka适用)



12050
12051
12052
# File 'lib/v20190819/models.rb', line 12050

def CompressionType
  @CompressionType
end

#MsgMultipleObject

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

Parameters:

  • Resource:

    单独售卖Topic的Topic名称

  • OffsetType:

    Offset类型,最开始位置earliest,最新位置latest,时间点位置timestamp

  • StartTime:

    Offset类型为timestamp时必传,传时间戳,精确到秒

  • TopicId:

    Topic的TopicId【出参】

  • CompressionType:

    写入Topic时是否进行压缩,不开启填"none",开启的话,可选择"gzip", "snappy", "lz4"中的一个进行填写。

  • UseAutoCreateTopic:

    使用的Topic是否需要自动创建(目前只支持SOURCE流入任务)

  • MsgMultiple:

    源topic消息1条扩增成msgMultiple条写入目标topic(该参数目前只有ckafka流入ckafka适用)



12050
12051
12052
# File 'lib/v20190819/models.rb', line 12050

def MsgMultiple
  @MsgMultiple
end

#OffsetTypeObject

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

Parameters:

  • Resource:

    单独售卖Topic的Topic名称

  • OffsetType:

    Offset类型,最开始位置earliest,最新位置latest,时间点位置timestamp

  • StartTime:

    Offset类型为timestamp时必传,传时间戳,精确到秒

  • TopicId:

    Topic的TopicId【出参】

  • CompressionType:

    写入Topic时是否进行压缩,不开启填"none",开启的话,可选择"gzip", "snappy", "lz4"中的一个进行填写。

  • UseAutoCreateTopic:

    使用的Topic是否需要自动创建(目前只支持SOURCE流入任务)

  • MsgMultiple:

    源topic消息1条扩增成msgMultiple条写入目标topic(该参数目前只有ckafka流入ckafka适用)



12050
12051
12052
# File 'lib/v20190819/models.rb', line 12050

def OffsetType
  @OffsetType
end

#ResourceObject

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

Parameters:

  • Resource:

    单独售卖Topic的Topic名称

  • OffsetType:

    Offset类型,最开始位置earliest,最新位置latest,时间点位置timestamp

  • StartTime:

    Offset类型为timestamp时必传,传时间戳,精确到秒

  • TopicId:

    Topic的TopicId【出参】

  • CompressionType:

    写入Topic时是否进行压缩,不开启填"none",开启的话,可选择"gzip", "snappy", "lz4"中的一个进行填写。

  • UseAutoCreateTopic:

    使用的Topic是否需要自动创建(目前只支持SOURCE流入任务)

  • MsgMultiple:

    源topic消息1条扩增成msgMultiple条写入目标topic(该参数目前只有ckafka流入ckafka适用)



12050
12051
12052
# File 'lib/v20190819/models.rb', line 12050

def Resource
  @Resource
end

#StartTimeObject

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

Parameters:

  • Resource:

    单独售卖Topic的Topic名称

  • OffsetType:

    Offset类型,最开始位置earliest,最新位置latest,时间点位置timestamp

  • StartTime:

    Offset类型为timestamp时必传,传时间戳,精确到秒

  • TopicId:

    Topic的TopicId【出参】

  • CompressionType:

    写入Topic时是否进行压缩,不开启填"none",开启的话,可选择"gzip", "snappy", "lz4"中的一个进行填写。

  • UseAutoCreateTopic:

    使用的Topic是否需要自动创建(目前只支持SOURCE流入任务)

  • MsgMultiple:

    源topic消息1条扩增成msgMultiple条写入目标topic(该参数目前只有ckafka流入ckafka适用)



12050
12051
12052
# File 'lib/v20190819/models.rb', line 12050

def StartTime
  @StartTime
end

#TopicIdObject

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

Parameters:

  • Resource:

    单独售卖Topic的Topic名称

  • OffsetType:

    Offset类型,最开始位置earliest,最新位置latest,时间点位置timestamp

  • StartTime:

    Offset类型为timestamp时必传,传时间戳,精确到秒

  • TopicId:

    Topic的TopicId【出参】

  • CompressionType:

    写入Topic时是否进行压缩,不开启填"none",开启的话,可选择"gzip", "snappy", "lz4"中的一个进行填写。

  • UseAutoCreateTopic:

    使用的Topic是否需要自动创建(目前只支持SOURCE流入任务)

  • MsgMultiple:

    源topic消息1条扩增成msgMultiple条写入目标topic(该参数目前只有ckafka流入ckafka适用)



12050
12051
12052
# File 'lib/v20190819/models.rb', line 12050

def TopicId
  @TopicId
end

#UseAutoCreateTopicObject

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

Parameters:

  • Resource:

    单独售卖Topic的Topic名称

  • OffsetType:

    Offset类型,最开始位置earliest,最新位置latest,时间点位置timestamp

  • StartTime:

    Offset类型为timestamp时必传,传时间戳,精确到秒

  • TopicId:

    Topic的TopicId【出参】

  • CompressionType:

    写入Topic时是否进行压缩,不开启填"none",开启的话,可选择"gzip", "snappy", "lz4"中的一个进行填写。

  • UseAutoCreateTopic:

    使用的Topic是否需要自动创建(目前只支持SOURCE流入任务)

  • MsgMultiple:

    源topic消息1条扩增成msgMultiple条写入目标topic(该参数目前只有ckafka流入ckafka适用)



12050
12051
12052
# File 'lib/v20190819/models.rb', line 12050

def UseAutoCreateTopic
  @UseAutoCreateTopic
end

Instance Method Details

#deserialize(params) ⇒ Object



12062
12063
12064
12065
12066
12067
12068
12069
12070
# File 'lib/v20190819/models.rb', line 12062

def deserialize(params)
  @Resource = params['Resource']
  @OffsetType = params['OffsetType']
  @StartTime = params['StartTime']
  @TopicId = params['TopicId']
  @CompressionType = params['CompressionType']
  @UseAutoCreateTopic = params['UseAutoCreateTopic']
  @MsgMultiple = params['MsgMultiple']
end