Class: TencentCloud::Cls::V20201016::CreateKafkaRechargeRequest

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

Overview

CreateKafkaRecharge请求参数结构体

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(topicid = nil, name = nil, kafkatype = nil, userkafkatopics = nil, offset = nil, logrechargerule = nil, kafkainstance = nil, serveraddr = nil, isencryptionaddr = nil, protocol = nil, consumergroupname = nil, userkafkameta = nil) ⇒ CreateKafkaRechargeRequest

Returns a new instance of CreateKafkaRechargeRequest.



3980
3981
3982
3983
3984
3985
3986
3987
3988
3989
3990
3991
3992
3993
 
# File 'lib/v20201016/models.rb', line 3980

def initialize(topicid=nil, name=nil, kafkatype=nil, userkafkatopics=nil, offset=nil, logrechargerule=nil, kafkainstance=nil, serveraddr=nil, isencryptionaddr=nil, protocol=nil, consumergroupname=nil, userkafkameta=nil)
  @TopicId = topicid
  @Name = name
  @KafkaType = kafkatype
  @UserKafkaTopics = userkafkatopics
  @Offset = offset
  @LogRechargeRule = logrechargerule
  @KafkaInstance = kafkainstance
  @ServerAddr = serveraddr
  @IsEncryptionAddr = isencryptionaddr
  @Protocol = protocol
  @ConsumerGroupName = consumergroupname
  @UserKafkaMeta = userkafkameta
end

Instance Attribute Details

#ConsumerGroupName ⇒ Object

  • 通过 获取日志主题列表 获取日志主题Id。
  • 通过 创建日志主题 获取日志主题Id。
  • 通过 获取实例列表信息 获取实例id。 KafkaType为1并且IsEncryptionAddr为true时Protocol必填。
  • 消费组是 Kafka 提供的可扩展且具有容错性的消费者机制，一个消费组中存在多个消费者，组内的所有消费者共同消费订阅 Topic 中的消息。一个消费者可同时消费多个 Partition，但一个 Partition 只能被消费组内的一个消费者消费。

Parameters:

  • TopicId: —

    导入CLS目标TopicId。

  • Name: —

    Kafka导入配置名称

  • KafkaType: —

    导入Kafka类型，0: 腾讯云CKafka，1: 用户自建Kafka

  • UserKafkaTopics: —

    用户需要导入的Kafka相关topic列表，多个topic之间使用半角逗号隔开

  • Offset: —

    导入数据位置，-2:最早（默认），-1：最晚

  • LogRechargeRule: —

    日志导入规则。

  • KafkaInstance: —

    腾讯云CKafka实例ID，KafkaType为0时必填。

  • ServerAddr: —

    服务地址，KafkaType为1时必填。

  • IsEncryptionAddr: —

    ServerAddr是否为加密连接，KafkaType为1时必填。

  • Protocol: —

    加密访问协议。

  • ConsumerGroupName: —

    用户Kafka消费组名称。

  • UserKafkaMeta: —

    用户kafka拓展信息



3978
3979
3980
 
# File 'lib/v20201016/models.rb', line 3978

def ConsumerGroupName
  @ConsumerGroupName
end

#IsEncryptionAddr ⇒ Object

  • 通过 获取日志主题列表 获取日志主题Id。
  • 通过 创建日志主题 获取日志主题Id。
  • 通过 获取实例列表信息 获取实例id。 KafkaType为1并且IsEncryptionAddr为true时Protocol必填。
  • 消费组是 Kafka 提供的可扩展且具有容错性的消费者机制，一个消费组中存在多个消费者，组内的所有消费者共同消费订阅 Topic 中的消息。一个消费者可同时消费多个 Partition，但一个 Partition 只能被消费组内的一个消费者消费。

Parameters:

  • TopicId: —

    导入CLS目标TopicId。

  • Name: —

    Kafka导入配置名称

  • KafkaType: —

    导入Kafka类型，0: 腾讯云CKafka，1: 用户自建Kafka

  • UserKafkaTopics: —

    用户需要导入的Kafka相关topic列表，多个topic之间使用半角逗号隔开

  • Offset: —

    导入数据位置，-2:最早（默认），-1：最晚

  • LogRechargeRule: —

    日志导入规则。

  • KafkaInstance: —

    腾讯云CKafka实例ID，KafkaType为0时必填。

  • ServerAddr: —

    服务地址，KafkaType为1时必填。

  • IsEncryptionAddr: —

    ServerAddr是否为加密连接，KafkaType为1时必填。

  • Protocol: —

    加密访问协议。

  • ConsumerGroupName: —

    用户Kafka消费组名称。

  • UserKafkaMeta: —

    用户kafka拓展信息



3978
3979
3980
 
# File 'lib/v20201016/models.rb', line 3978

def IsEncryptionAddr
  @IsEncryptionAddr
end

#KafkaInstance ⇒ Object

  • 通过 获取日志主题列表 获取日志主题Id。
  • 通过 创建日志主题 获取日志主题Id。
  • 通过 获取实例列表信息 获取实例id。 KafkaType为1并且IsEncryptionAddr为true时Protocol必填。
  • 消费组是 Kafka 提供的可扩展且具有容错性的消费者机制，一个消费组中存在多个消费者，组内的所有消费者共同消费订阅 Topic 中的消息。一个消费者可同时消费多个 Partition，但一个 Partition 只能被消费组内的一个消费者消费。

Parameters:

  • TopicId: —

    导入CLS目标TopicId。

  • Name: —

    Kafka导入配置名称

  • KafkaType: —

    导入Kafka类型，0: 腾讯云CKafka，1: 用户自建Kafka

  • UserKafkaTopics: —

    用户需要导入的Kafka相关topic列表，多个topic之间使用半角逗号隔开

  • Offset: —

    导入数据位置，-2:最早（默认），-1：最晚

  • LogRechargeRule: —

    日志导入规则。

  • KafkaInstance: —

    腾讯云CKafka实例ID，KafkaType为0时必填。

  • ServerAddr: —

    服务地址，KafkaType为1时必填。

  • IsEncryptionAddr: —

    ServerAddr是否为加密连接，KafkaType为1时必填。

  • Protocol: —

    加密访问协议。

  • ConsumerGroupName: —

    用户Kafka消费组名称。

  • UserKafkaMeta: —

    用户kafka拓展信息



3978
3979
3980
 
# File 'lib/v20201016/models.rb', line 3978

def KafkaInstance
  @KafkaInstance
end

#KafkaType ⇒ Object

  • 通过 获取日志主题列表 获取日志主题Id。
  • 通过 创建日志主题 获取日志主题Id。
  • 通过 获取实例列表信息 获取实例id。 KafkaType为1并且IsEncryptionAddr为true时Protocol必填。
  • 消费组是 Kafka 提供的可扩展且具有容错性的消费者机制，一个消费组中存在多个消费者，组内的所有消费者共同消费订阅 Topic 中的消息。一个消费者可同时消费多个 Partition，但一个 Partition 只能被消费组内的一个消费者消费。

Parameters:

  • TopicId: —

    导入CLS目标TopicId。

  • Name: —

    Kafka导入配置名称

  • KafkaType: —

    导入Kafka类型，0: 腾讯云CKafka，1: 用户自建Kafka

  • UserKafkaTopics: —

    用户需要导入的Kafka相关topic列表，多个topic之间使用半角逗号隔开

  • Offset: —

    导入数据位置，-2:最早（默认），-1：最晚

  • LogRechargeRule: —

    日志导入规则。

  • KafkaInstance: —

    腾讯云CKafka实例ID，KafkaType为0时必填。

  • ServerAddr: —

    服务地址，KafkaType为1时必填。

  • IsEncryptionAddr: —

    ServerAddr是否为加密连接，KafkaType为1时必填。

  • Protocol: —

    加密访问协议。

  • ConsumerGroupName: —

    用户Kafka消费组名称。

  • UserKafkaMeta: —

    用户kafka拓展信息



3978
3979
3980
 
# File 'lib/v20201016/models.rb', line 3978

def KafkaType
  @KafkaType
end

#LogRechargeRule ⇒ Object

  • 通过 获取日志主题列表 获取日志主题Id。
  • 通过 创建日志主题 获取日志主题Id。
  • 通过 获取实例列表信息 获取实例id。 KafkaType为1并且IsEncryptionAddr为true时Protocol必填。
  • 消费组是 Kafka 提供的可扩展且具有容错性的消费者机制，一个消费组中存在多个消费者，组内的所有消费者共同消费订阅 Topic 中的消息。一个消费者可同时消费多个 Partition，但一个 Partition 只能被消费组内的一个消费者消费。

Parameters:

  • TopicId: —

    导入CLS目标TopicId。

  • Name: —

    Kafka导入配置名称

  • KafkaType: —

    导入Kafka类型，0: 腾讯云CKafka，1: 用户自建Kafka

  • UserKafkaTopics: —

    用户需要导入的Kafka相关topic列表，多个topic之间使用半角逗号隔开

  • Offset: —

    导入数据位置，-2:最早（默认），-1：最晚

  • LogRechargeRule: —

    日志导入规则。

  • KafkaInstance: —

    腾讯云CKafka实例ID，KafkaType为0时必填。

  • ServerAddr: —

    服务地址，KafkaType为1时必填。

  • IsEncryptionAddr: —

    ServerAddr是否为加密连接，KafkaType为1时必填。

  • Protocol: —

    加密访问协议。

  • ConsumerGroupName: —

    用户Kafka消费组名称。

  • UserKafkaMeta: —

    用户kafka拓展信息



3978
3979
3980
 
# File 'lib/v20201016/models.rb', line 3978

def LogRechargeRule
  @LogRechargeRule
end

#Name ⇒ Object

  • 通过 获取日志主题列表 获取日志主题Id。
  • 通过 创建日志主题 获取日志主题Id。
  • 通过 获取实例列表信息 获取实例id。 KafkaType为1并且IsEncryptionAddr为true时Protocol必填。
  • 消费组是 Kafka 提供的可扩展且具有容错性的消费者机制，一个消费组中存在多个消费者，组内的所有消费者共同消费订阅 Topic 中的消息。一个消费者可同时消费多个 Partition，但一个 Partition 只能被消费组内的一个消费者消费。

Parameters:

  • TopicId: —

    导入CLS目标TopicId。

  • Name: —

    Kafka导入配置名称

  • KafkaType: —

    导入Kafka类型，0: 腾讯云CKafka，1: 用户自建Kafka

  • UserKafkaTopics: —

    用户需要导入的Kafka相关topic列表，多个topic之间使用半角逗号隔开

  • Offset: —

    导入数据位置，-2:最早（默认），-1：最晚

  • LogRechargeRule: —

    日志导入规则。

  • KafkaInstance: —

    腾讯云CKafka实例ID，KafkaType为0时必填。

  • ServerAddr: —

    服务地址，KafkaType为1时必填。

  • IsEncryptionAddr: —

    ServerAddr是否为加密连接，KafkaType为1时必填。

  • Protocol: —

    加密访问协议。

  • ConsumerGroupName: —

    用户Kafka消费组名称。

  • UserKafkaMeta: —

    用户kafka拓展信息



3978
3979
3980
 
# File 'lib/v20201016/models.rb', line 3978

def Name
  @Name
end

#Offset ⇒ Object

  • 通过 获取日志主题列表 获取日志主题Id。
  • 通过 创建日志主题 获取日志主题Id。
  • 通过 获取实例列表信息 获取实例id。 KafkaType为1并且IsEncryptionAddr为true时Protocol必填。
  • 消费组是 Kafka 提供的可扩展且具有容错性的消费者机制，一个消费组中存在多个消费者，组内的所有消费者共同消费订阅 Topic 中的消息。一个消费者可同时消费多个 Partition，但一个 Partition 只能被消费组内的一个消费者消费。

Parameters:

  • TopicId: —

    导入CLS目标TopicId。

  • Name: —

    Kafka导入配置名称

  • KafkaType: —

    导入Kafka类型，0: 腾讯云CKafka，1: 用户自建Kafka

  • UserKafkaTopics: —

    用户需要导入的Kafka相关topic列表，多个topic之间使用半角逗号隔开

  • Offset: —

    导入数据位置，-2:最早（默认），-1：最晚

  • LogRechargeRule: —

    日志导入规则。

  • KafkaInstance: —

    腾讯云CKafka实例ID，KafkaType为0时必填。

  • ServerAddr: —

    服务地址，KafkaType为1时必填。

  • IsEncryptionAddr: —

    ServerAddr是否为加密连接，KafkaType为1时必填。

  • Protocol: —

    加密访问协议。

  • ConsumerGroupName: —

    用户Kafka消费组名称。

  • UserKafkaMeta: —

    用户kafka拓展信息



3978
3979
3980
 
# File 'lib/v20201016/models.rb', line 3978

def Offset
  @Offset
end

#Protocol ⇒ Object

  • 通过 获取日志主题列表 获取日志主题Id。
  • 通过 创建日志主题 获取日志主题Id。
  • 通过 获取实例列表信息 获取实例id。 KafkaType为1并且IsEncryptionAddr为true时Protocol必填。
  • 消费组是 Kafka 提供的可扩展且具有容错性的消费者机制，一个消费组中存在多个消费者，组内的所有消费者共同消费订阅 Topic 中的消息。一个消费者可同时消费多个 Partition，但一个 Partition 只能被消费组内的一个消费者消费。

Parameters:

  • TopicId: —

    导入CLS目标TopicId。

  • Name: —

    Kafka导入配置名称

  • KafkaType: —

    导入Kafka类型，0: 腾讯云CKafka，1: 用户自建Kafka

  • UserKafkaTopics: —

    用户需要导入的Kafka相关topic列表，多个topic之间使用半角逗号隔开

  • Offset: —

    导入数据位置，-2:最早（默认），-1：最晚

  • LogRechargeRule: —

    日志导入规则。

  • KafkaInstance: —

    腾讯云CKafka实例ID，KafkaType为0时必填。

  • ServerAddr: —

    服务地址，KafkaType为1时必填。

  • IsEncryptionAddr: —

    ServerAddr是否为加密连接，KafkaType为1时必填。

  • Protocol: —

    加密访问协议。

  • ConsumerGroupName: —

    用户Kafka消费组名称。

  • UserKafkaMeta: —

    用户kafka拓展信息



3978
3979
3980
 
# File 'lib/v20201016/models.rb', line 3978

def Protocol
  @Protocol
end

#ServerAddr ⇒ Object

  • 通过 获取日志主题列表 获取日志主题Id。
  • 通过 创建日志主题 获取日志主题Id。
  • 通过 获取实例列表信息 获取实例id。 KafkaType为1并且IsEncryptionAddr为true时Protocol必填。
  • 消费组是 Kafka 提供的可扩展且具有容错性的消费者机制，一个消费组中存在多个消费者，组内的所有消费者共同消费订阅 Topic 中的消息。一个消费者可同时消费多个 Partition，但一个 Partition 只能被消费组内的一个消费者消费。

Parameters:

  • TopicId: —

    导入CLS目标TopicId。

  • Name: —

    Kafka导入配置名称

  • KafkaType: —

    导入Kafka类型，0: 腾讯云CKafka，1: 用户自建Kafka

  • UserKafkaTopics: —

    用户需要导入的Kafka相关topic列表，多个topic之间使用半角逗号隔开

  • Offset: —

    导入数据位置，-2:最早（默认），-1：最晚

  • LogRechargeRule: —

    日志导入规则。

  • KafkaInstance: —

    腾讯云CKafka实例ID，KafkaType为0时必填。

  • ServerAddr: —

    服务地址，KafkaType为1时必填。

  • IsEncryptionAddr: —

    ServerAddr是否为加密连接，KafkaType为1时必填。

  • Protocol: —

    加密访问协议。

  • ConsumerGroupName: —

    用户Kafka消费组名称。

  • UserKafkaMeta: —

    用户kafka拓展信息



3978
3979
3980
 
# File 'lib/v20201016/models.rb', line 3978

def ServerAddr
  @ServerAddr
end

#TopicId ⇒ Object

  • 通过 获取日志主题列表 获取日志主题Id。
  • 通过 创建日志主题 获取日志主题Id。
  • 通过 获取实例列表信息 获取实例id。 KafkaType为1并且IsEncryptionAddr为true时Protocol必填。
  • 消费组是 Kafka 提供的可扩展且具有容错性的消费者机制，一个消费组中存在多个消费者，组内的所有消费者共同消费订阅 Topic 中的消息。一个消费者可同时消费多个 Partition，但一个 Partition 只能被消费组内的一个消费者消费。

Parameters:

  • TopicId: —

    导入CLS目标TopicId。

  • Name: —

    Kafka导入配置名称

  • KafkaType: —

    导入Kafka类型，0: 腾讯云CKafka，1: 用户自建Kafka

  • UserKafkaTopics: —

    用户需要导入的Kafka相关topic列表，多个topic之间使用半角逗号隔开

  • Offset: —

    导入数据位置，-2:最早（默认），-1：最晚

  • LogRechargeRule: —

    日志导入规则。

  • KafkaInstance: —

    腾讯云CKafka实例ID，KafkaType为0时必填。

  • ServerAddr: —

    服务地址，KafkaType为1时必填。

  • IsEncryptionAddr: —

    ServerAddr是否为加密连接，KafkaType为1时必填。

  • Protocol: —

    加密访问协议。

  • ConsumerGroupName: —

    用户Kafka消费组名称。

  • UserKafkaMeta: —

    用户kafka拓展信息



3978
3979
3980
 
# File 'lib/v20201016/models.rb', line 3978

def TopicId
  @TopicId
end

#UserKafkaMeta ⇒ Object

  • 通过 获取日志主题列表 获取日志主题Id。
  • 通过 创建日志主题 获取日志主题Id。
  • 通过 获取实例列表信息 获取实例id。 KafkaType为1并且IsEncryptionAddr为true时Protocol必填。
  • 消费组是 Kafka 提供的可扩展且具有容错性的消费者机制，一个消费组中存在多个消费者，组内的所有消费者共同消费订阅 Topic 中的消息。一个消费者可同时消费多个 Partition，但一个 Partition 只能被消费组内的一个消费者消费。

Parameters:

  • TopicId: —

    导入CLS目标TopicId。

  • Name: —

    Kafka导入配置名称

  • KafkaType: —

    导入Kafka类型，0: 腾讯云CKafka，1: 用户自建Kafka

  • UserKafkaTopics: —

    用户需要导入的Kafka相关topic列表，多个topic之间使用半角逗号隔开

  • Offset: —

    导入数据位置，-2:最早（默认），-1：最晚

  • LogRechargeRule: —

    日志导入规则。

  • KafkaInstance: —

    腾讯云CKafka实例ID，KafkaType为0时必填。

  • ServerAddr: —

    服务地址，KafkaType为1时必填。

  • IsEncryptionAddr: —

    ServerAddr是否为加密连接，KafkaType为1时必填。

  • Protocol: —

    加密访问协议。

  • ConsumerGroupName: —

    用户Kafka消费组名称。

  • UserKafkaMeta: —

    用户kafka拓展信息



3978
3979
3980
 
# File 'lib/v20201016/models.rb', line 3978

def UserKafkaMeta
  @UserKafkaMeta
end

#UserKafkaTopics ⇒ Object

  • 通过 获取日志主题列表 获取日志主题Id。
  • 通过 创建日志主题 获取日志主题Id。
  • 通过 获取实例列表信息 获取实例id。 KafkaType为1并且IsEncryptionAddr为true时Protocol必填。
  • 消费组是 Kafka 提供的可扩展且具有容错性的消费者机制，一个消费组中存在多个消费者，组内的所有消费者共同消费订阅 Topic 中的消息。一个消费者可同时消费多个 Partition，但一个 Partition 只能被消费组内的一个消费者消费。

Parameters:

  • TopicId: —

    导入CLS目标TopicId。

  • Name: —

    Kafka导入配置名称

  • KafkaType: —

    导入Kafka类型，0: 腾讯云CKafka，1: 用户自建Kafka

  • UserKafkaTopics: —

    用户需要导入的Kafka相关topic列表，多个topic之间使用半角逗号隔开

  • Offset: —

    导入数据位置，-2:最早（默认），-1：最晚

  • LogRechargeRule: —

    日志导入规则。

  • KafkaInstance: —

    腾讯云CKafka实例ID，KafkaType为0时必填。

  • ServerAddr: —

    服务地址，KafkaType为1时必填。

  • IsEncryptionAddr: —

    ServerAddr是否为加密连接，KafkaType为1时必填。

  • Protocol: —

    加密访问协议。

  • ConsumerGroupName: —

    用户Kafka消费组名称。

  • UserKafkaMeta: —

    用户kafka拓展信息



3978
3979
3980
 
# File 'lib/v20201016/models.rb', line 3978

def UserKafkaTopics
  @UserKafkaTopics
end

Instance Method Details

#deserialize(params) ⇒ Object 



3995
3996
3997
3998
3999
4000
4001
4002
4003
4004
4005
4006
4007
4008
4009
4010
4011
4012
4013
4014
4015
4016
4017
 
# File 'lib/v20201016/models.rb', line 3995

def deserialize(params)
  @TopicId = params['TopicId']
  @Name = params['Name']
  @KafkaType = params['KafkaType']
  @UserKafkaTopics = params['UserKafkaTopics']
  @Offset = params['Offset']
  unless params['LogRechargeRule'].nil?
    @LogRechargeRule = LogRechargeRuleInfo.new
    @LogRechargeRule.deserialize(params['LogRechargeRule'])
  end
  @KafkaInstance = params['KafkaInstance']
  @ServerAddr = params['ServerAddr']
  @IsEncryptionAddr = params['IsEncryptionAddr']
  unless params['Protocol'].nil?
    @Protocol = KafkaProtocolInfo.new
    @Protocol.deserialize(params['Protocol'])
  end
  @ConsumerGroupName = params['ConsumerGroupName']
  unless params['UserKafkaMeta'].nil?
    @UserKafkaMeta = UserKafkaMeta.new
    @UserKafkaMeta.deserialize(params['UserKafkaMeta'])
  end
end