models.rb in tencentcloud-sdk-ckafka-3.0.635

- old
+ new

@@ -863,43 +863,70 @@
       end
 
       # ClickHouse类型入参
       class ClickHouseParam < TencentCloud::Common::AbstractModel
         # @param Cluster: ClickHouse的集群
+        # 注意：此字段可能返回 null，表示取不到有效值。
         # @type Cluster: String
         # @param Database: ClickHouse的数据库名
+        # 注意：此字段可能返回 null，表示取不到有效值。
         # @type Database: String
         # @param Table: ClickHouse的数据表名
+        # 注意：此字段可能返回 null，表示取不到有效值。
         # @type Table: String
         # @param Schema: ClickHouse的schema
+        # 注意：此字段可能返回 null，表示取不到有效值。
         # @type Schema: Array
         # @param Resource: 实例资源
+        # 注意：此字段可能返回 null，表示取不到有效值。
         # @type Resource: String
         # @param Ip: ClickHouse的连接ip
+        # 注意：此字段可能返回 null，表示取不到有效值。
         # @type Ip: String
         # @param Port: ClickHouse的连接port
+        # 注意：此字段可能返回 null，表示取不到有效值。
         # @type Port: Integer
         # @param UserName: ClickHouse的用户名
+        # 注意：此字段可能返回 null，表示取不到有效值。
         # @type UserName: String
         # @param Password: ClickHouse的密码
+        # 注意：此字段可能返回 null，表示取不到有效值。
         # @type Password: String
         # @param ServiceVip: 实例vip
+        # 注意：此字段可能返回 null，表示取不到有效值。
         # @type ServiceVip: String
         # @param UniqVpcId: 实例的vpcId
+        # 注意：此字段可能返回 null，表示取不到有效值。
         # @type UniqVpcId: String
         # @param SelfBuilt: 是否为自建集群
+        # 注意：此字段可能返回 null，表示取不到有效值。
         # @type SelfBuilt: Boolean
         # @param DropInvalidMessage: ClickHouse是否抛弃解析失败的消息，默认为true
+        # 注意：此字段可能返回 null，表示取不到有效值。
         # @type DropInvalidMessage: Boolean
         # @param Type: ClickHouse 类型，emr-clickhouse : "emr";cdw-clickhouse : "cdwch";自建 : ""
+        # 注意：此字段可能返回 null，表示取不到有效值。
         # @type Type: String
         # @param DropCls: 当设置成员参数DropInvalidMessageToCls设置为true时,DropInvalidMessage参数失效
+        # 注意：此字段可能返回 null，表示取不到有效值。
         # @type DropCls: :class:`Tencentcloud::Ckafka.v20190819.models.DropCls`
+        # @param BatchSize: 每批次投递到 ClickHouse 表消息数量，默认为 1000 条。
+        # 提高该参数值，有利于减少往  ClickHouse 投递的次数，但在错误消息过多及网络不稳定等极端情况下时，可能导致频繁重试影响效率。
+        # 注意：此字段可能返回 null，表示取不到有效值。
+        # @type BatchSize: Integer
+        # @param ConsumerFetchMinBytes: 每次从 topic 中拉取消息大小，默认为 1MB，即至少要从 topic 中批量拉取 1MB 消息，才进行数据投递到 ClickHouse 操作。
+        # 提高该参数值，有利于减少往  ClickHouse 投递的次数，但在错误消息过多及网络不稳定等极端情况下时，可能导致频繁重试影响效率。
+        # 注意：此字段可能返回 null，表示取不到有效值。
+        # @type ConsumerFetchMinBytes: Integer
+        # @param ConsumerFetchMaxWaitMs: 每次从 topic 拉取消息最大等待时间，当超过当前最大等待时间时，即使没有拉取到 ConsumerFetchMinBytes 大小，也将进行 ClickHouse 投递操作。
+        # 提高该参数值，有利于减少往  ClickHouse 投递的次数，但在错误消息过多及网络不稳定等极端情况下时，可能导致频繁重试影响效率。
+        # 注意：此字段可能返回 null，表示取不到有效值。
+        # @type ConsumerFetchMaxWaitMs: Integer
 
-        attr_accessor :Cluster, :Database, :Table, :Schema, :Resource, :Ip, :Port, :UserName, :Password, :ServiceVip, :UniqVpcId, :SelfBuilt, :DropInvalidMessage, :Type, :DropCls
+        attr_accessor :Cluster, :Database, :Table, :Schema, :Resource, :Ip, :Port, :UserName, :Password, :ServiceVip, :UniqVpcId, :SelfBuilt, :DropInvalidMessage, :Type, :DropCls, :BatchSize, :ConsumerFetchMinBytes, :ConsumerFetchMaxWaitMs
 
-        def initialize(cluster=nil, database=nil, table=nil, schema=nil, resource=nil, ip=nil, port=nil, username=nil, password=nil, servicevip=nil, uniqvpcid=nil, selfbuilt=nil, dropinvalidmessage=nil, type=nil, dropcls=nil)
+        def initialize(cluster=nil, database=nil, table=nil, schema=nil, resource=nil, ip=nil, port=nil, username=nil, password=nil, servicevip=nil, uniqvpcid=nil, selfbuilt=nil, dropinvalidmessage=nil, type=nil, dropcls=nil, batchsize=nil, consumerfetchminbytes=nil, consumerfetchmaxwaitms=nil)
           @Cluster = cluster
           @Database = database
           @Table = table
           @Schema = schema
           @Resource = resource
@@ -911,10 +938,13 @@
           @UniqVpcId = uniqvpcid
           @SelfBuilt = selfbuilt
           @DropInvalidMessage = dropinvalidmessage
           @Type = type
           @DropCls = dropcls
+          @BatchSize = batchsize
+          @ConsumerFetchMinBytes = consumerfetchminbytes
+          @ConsumerFetchMaxWaitMs = consumerfetchmaxwaitms
         end
 
         def deserialize(params)
           @Cluster = params['Cluster']
           @Database = params['Database']
@@ -939,9 +969,12 @@
           @Type = params['Type']
           unless params['DropCls'].nil?
             @DropCls = DropCls.new
             @DropCls.deserialize(params['DropCls'])
           end
+          @BatchSize = params['BatchSize']
+          @ConsumerFetchMinBytes = params['ConsumerFetchMinBytes']
+          @ConsumerFetchMaxWaitMs = params['ConsumerFetchMaxWaitMs']
         end
       end
 
       # ClickHouse的Schema
       class ClickHouseSchema < TencentCloud::Common::AbstractModel