Class: TencentCloud::Cls::V20201016::PreviewKafkaRechargeRequest

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

Overview

PreviewKafkaRecharge请求参数结构体

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(previewtype = nil, kafkatype = nil, userkafkatopics = nil, offset = nil, kafkainstance = nil, serveraddr = nil, isencryptionaddr = nil, protocol = nil, consumergroupname = nil, logrechargerule = nil, userkafkameta = nil) ⇒ PreviewKafkaRechargeRequest

Returns a new instance of PreviewKafkaRechargeRequest.



16128
16129
16130
16131
16132
16133
16134
16135
16136
16137
16138
16139
16140
 
# File 'lib/v20201016/models.rb', line 16128

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

Instance Attribute Details

#ConsumerGroupName ⇒ Object

  • 消费组是 Kafka 提供的可扩展且具有容错性的消费者机制，一个消费组中存在多个消费者，组内的所有消费者共同消费订阅 Topic 中的消息。一个消费者可同时消费多个 Partition，但一个 Partition 只能被消费组内的一个消费者消费。

Parameters:

  • LogRechargeRule: —

    日志导入规则

  • UserKafkaMeta: —

    用户kafka拓展信息



16126
16127
16128
 
# File 'lib/v20201016/models.rb', line 16126

def ConsumerGroupName
  @ConsumerGroupName
end

#IsEncryptionAddr ⇒ Object

  • 消费组是 Kafka 提供的可扩展且具有容错性的消费者机制，一个消费组中存在多个消费者，组内的所有消费者共同消费订阅 Topic 中的消息。一个消费者可同时消费多个 Partition，但一个 Partition 只能被消费组内的一个消费者消费。

Parameters:

  • LogRechargeRule: —

    日志导入规则

  • UserKafkaMeta: —

    用户kafka拓展信息



16126
16127
16128
 
# File 'lib/v20201016/models.rb', line 16126

def IsEncryptionAddr
  @IsEncryptionAddr
end

#KafkaInstance ⇒ Object

  • 消费组是 Kafka 提供的可扩展且具有容错性的消费者机制，一个消费组中存在多个消费者，组内的所有消费者共同消费订阅 Topic 中的消息。一个消费者可同时消费多个 Partition，但一个 Partition 只能被消费组内的一个消费者消费。

Parameters:

  • LogRechargeRule: —

    日志导入规则

  • UserKafkaMeta: —

    用户kafka拓展信息



16126
16127
16128
 
# File 'lib/v20201016/models.rb', line 16126

def KafkaInstance
  @KafkaInstance
end

#KafkaType ⇒ Object

  • 消费组是 Kafka 提供的可扩展且具有容错性的消费者机制，一个消费组中存在多个消费者，组内的所有消费者共同消费订阅 Topic 中的消息。一个消费者可同时消费多个 Partition，但一个 Partition 只能被消费组内的一个消费者消费。

Parameters:

  • LogRechargeRule: —

    日志导入规则

  • UserKafkaMeta: —

    用户kafka拓展信息



16126
16127
16128
 
# File 'lib/v20201016/models.rb', line 16126

def KafkaType
  @KafkaType
end

#LogRechargeRule ⇒ Object

  • 消费组是 Kafka 提供的可扩展且具有容错性的消费者机制，一个消费组中存在多个消费者，组内的所有消费者共同消费订阅 Topic 中的消息。一个消费者可同时消费多个 Partition，但一个 Partition 只能被消费组内的一个消费者消费。

Parameters:

  • LogRechargeRule: —

    日志导入规则

  • UserKafkaMeta: —

    用户kafka拓展信息



16126
16127
16128
 
# File 'lib/v20201016/models.rb', line 16126

def LogRechargeRule
  @LogRechargeRule
end

#Offset ⇒ Object

  • 消费组是 Kafka 提供的可扩展且具有容错性的消费者机制，一个消费组中存在多个消费者，组内的所有消费者共同消费订阅 Topic 中的消息。一个消费者可同时消费多个 Partition，但一个 Partition 只能被消费组内的一个消费者消费。

Parameters:

  • LogRechargeRule: —

    日志导入规则

  • UserKafkaMeta: —

    用户kafka拓展信息



16126
16127
16128
 
# File 'lib/v20201016/models.rb', line 16126

def Offset
  @Offset
end

#PreviewType ⇒ Object

  • 消费组是 Kafka 提供的可扩展且具有容错性的消费者机制，一个消费组中存在多个消费者，组内的所有消费者共同消费订阅 Topic 中的消息。一个消费者可同时消费多个 Partition，但一个 Partition 只能被消费组内的一个消费者消费。

Parameters:

  • LogRechargeRule: —

    日志导入规则

  • UserKafkaMeta: —

    用户kafka拓展信息



16126
16127
16128
 
# File 'lib/v20201016/models.rb', line 16126

def PreviewType
  @PreviewType
end

#Protocol ⇒ Object

  • 消费组是 Kafka 提供的可扩展且具有容错性的消费者机制，一个消费组中存在多个消费者，组内的所有消费者共同消费订阅 Topic 中的消息。一个消费者可同时消费多个 Partition，但一个 Partition 只能被消费组内的一个消费者消费。

Parameters:

  • LogRechargeRule: —

    日志导入规则

  • UserKafkaMeta: —

    用户kafka拓展信息



16126
16127
16128
 
# File 'lib/v20201016/models.rb', line 16126

def Protocol
  @Protocol
end

#ServerAddr ⇒ Object

  • 消费组是 Kafka 提供的可扩展且具有容错性的消费者机制，一个消费组中存在多个消费者，组内的所有消费者共同消费订阅 Topic 中的消息。一个消费者可同时消费多个 Partition，但一个 Partition 只能被消费组内的一个消费者消费。

Parameters:

  • LogRechargeRule: —

    日志导入规则

  • UserKafkaMeta: —

    用户kafka拓展信息



16126
16127
16128
 
# File 'lib/v20201016/models.rb', line 16126

def ServerAddr
  @ServerAddr
end

#UserKafkaMeta ⇒ Object

  • 消费组是 Kafka 提供的可扩展且具有容错性的消费者机制，一个消费组中存在多个消费者，组内的所有消费者共同消费订阅 Topic 中的消息。一个消费者可同时消费多个 Partition，但一个 Partition 只能被消费组内的一个消费者消费。

Parameters:

  • LogRechargeRule: —

    日志导入规则

  • UserKafkaMeta: —

    用户kafka拓展信息



16126
16127
16128
 
# File 'lib/v20201016/models.rb', line 16126

def UserKafkaMeta
  @UserKafkaMeta
end

#UserKafkaTopics ⇒ Object

  • 消费组是 Kafka 提供的可扩展且具有容错性的消费者机制，一个消费组中存在多个消费者，组内的所有消费者共同消费订阅 Topic 中的消息。一个消费者可同时消费多个 Partition，但一个 Partition 只能被消费组内的一个消费者消费。

Parameters:

  • LogRechargeRule: —

    日志导入规则

  • UserKafkaMeta: —

    用户kafka拓展信息



16126
16127
16128
 
# File 'lib/v20201016/models.rb', line 16126

def UserKafkaTopics
  @UserKafkaTopics
end

Instance Method Details

#deserialize(params) ⇒ Object 



16142
16143
16144
16145
16146
16147
16148
16149
16150
16151
16152
16153
16154
16155
16156
16157
16158
16159
16160
16161
16162
16163
 
# File 'lib/v20201016/models.rb', line 16142

def deserialize(params)
  @PreviewType = params['PreviewType']
  @KafkaType = params['KafkaType']
  @UserKafkaTopics = params['UserKafkaTopics']
  @Offset = params['Offset']
  @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['LogRechargeRule'].nil?
    @LogRechargeRule = LogRechargeRuleInfo.new
    @LogRechargeRule.deserialize(params['LogRechargeRule'])
  end
  unless params['UserKafkaMeta'].nil?
    @UserKafkaMeta = UserKafkaMeta.new
    @UserKafkaMeta.deserialize(params['UserKafkaMeta'])
  end
end