models.rb in tencentcloud-sdk-ckafka-1.0.230

- old
+ new

@@ -235,10 +235,30 @@
             end
           end
         end
       end
 
+      # 批量发送消息内容
+      class BatchContent < TencentCloud::Common::AbstractModel
+        # @param Body: 发送的消息体
+        # @type Body: String
+        # @param Key: 发送消息的键名
+        # @type Key: String
+
+        attr_accessor :Body, :Key
+        
+        def initialize(body=nil, key=nil)
+          @Body = body
+          @Key = key
+        end
+
+        def deserialize(params)
+          @Body = params['Body']
+          @Key = params['Key']
+        end
+      end
+
       # BatchCreateAcl请求参数结构体
       class BatchCreateAclRequest < TencentCloud::Common::AbstractModel
         # @param InstanceId: 实例ID
         # @type InstanceId: String
         # @param ResourceType: Acl资源类型，(2:TOPIC）
@@ -3923,9 +3943,56 @@
         def deserialize(params)
           @Flag = params['Flag']
           @Version = params['Version']
           @Platform = params['Platform']
           @SoldOut = params['SoldOut']
+        end
+      end
+
+      # SendMessage请求参数结构体
+      class SendMessageRequest < TencentCloud::Common::AbstractModel
+        # @param DataHubId: DataHub接入ID
+        # @type DataHubId: String
+        # @param Message: 发送消息内容
+        # @type Message: Array
+
+        attr_accessor :DataHubId, :Message
+        
+        def initialize(datahubid=nil, message=nil)
+          @DataHubId = datahubid
+          @Message = message
+        end
+
+        def deserialize(params)
+          @DataHubId = params['DataHubId']
+          unless params['Message'].nil?
+            @Message = []
+            params['Message'].each do |i|
+              batchcontent_tmp = BatchContent.new
+              batchcontent_tmp.deserialize(i)
+              @Message << batchcontent_tmp
+            end
+          end
+        end
+      end
+
+      # SendMessage返回参数结构体
+      class SendMessageResponse < TencentCloud::Common::AbstractModel
+        # @param MessageId: 消息ID列表
+        # @type MessageId: Array
+        # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
+        # @type RequestId: String
+
+        attr_accessor :MessageId, :RequestId
+        
+        def initialize(messageid=nil, requestid=nil)
+          @MessageId = messageid
+          @RequestId = requestid
+        end
+
+        def deserialize(params)
+          @MessageId = params['MessageId']
+          @RequestId = params['RequestId']
         end
       end
 
       # 订阅信息实体
       class SubscribedInfo < TencentCloud::Common::AbstractModel