-
Notifications
You must be signed in to change notification settings - Fork 283
/
CkafkaClient.java
955 lines (867 loc) · 37.4 KB
/
CkafkaClient.java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
687
688
689
690
691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714
715
716
717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
732
733
734
735
736
737
738
739
740
741
742
743
744
745
746
747
748
749
750
751
752
753
754
755
756
757
758
759
760
761
762
763
764
765
766
767
768
769
770
771
772
773
774
775
776
777
778
779
780
781
782
783
784
785
786
787
788
789
790
791
792
793
794
795
796
797
798
799
800
801
802
803
804
805
806
807
808
809
810
811
812
813
814
815
816
817
818
819
820
821
822
823
824
825
826
827
828
829
830
831
832
833
834
835
836
837
838
839
840
841
842
843
844
845
846
847
848
849
850
851
852
853
854
855
856
857
858
859
860
861
862
863
864
865
866
867
868
869
870
871
872
873
874
875
876
877
878
879
880
881
882
883
884
885
886
887
888
889
890
891
892
893
894
895
896
897
898
899
900
901
902
903
904
905
906
907
908
909
910
911
912
913
914
915
916
917
918
919
920
921
922
923
924
925
926
927
928
929
930
931
932
933
934
935
936
937
938
939
940
941
942
943
944
945
946
947
948
949
950
951
952
953
954
955
/*
* Copyright (c) 2017-2018 THL A29 Limited, a Tencent company. All Rights Reserved.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package com.tencentcloudapi.ckafka.v20190819;
import java.lang.reflect.Type;
import com.google.gson.JsonSyntaxException;
import com.google.gson.reflect.TypeToken;
import com.tencentcloudapi.common.exception.TencentCloudSDKException;
import com.tencentcloudapi.common.AbstractClient;
import com.tencentcloudapi.common.profile.ClientProfile;
import com.tencentcloudapi.common.JsonResponseModel;
import com.tencentcloudapi.common.Credential;
import com.tencentcloudapi.ckafka.v20190819.models.*;
public class CkafkaClient extends AbstractClient{
private static String endpoint = "ckafka.tencentcloudapi.com";
private static String service = "ckafka";
private static String version = "2019-08-19";
public CkafkaClient(Credential credential, String region) {
this(credential, region, new ClientProfile());
}
public CkafkaClient(Credential credential, String region, ClientProfile profile) {
super(CkafkaClient.endpoint, CkafkaClient.version, credential, region, profile);
}
/**
*给实例授权token
* @param req AuthorizeTokenRequest
* @return AuthorizeTokenResponse
* @throws TencentCloudSDKException
*/
public AuthorizeTokenResponse AuthorizeToken(AuthorizeTokenRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "AuthorizeToken", AuthorizeTokenResponse.class);
}
/**
*批量添加ACL策略
* @param req BatchCreateAclRequest
* @return BatchCreateAclResponse
* @throws TencentCloudSDKException
*/
public BatchCreateAclResponse BatchCreateAcl(BatchCreateAclRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "BatchCreateAcl", BatchCreateAclResponse.class);
}
/**
*批量修改消费组offset
* @param req BatchModifyGroupOffsetsRequest
* @return BatchModifyGroupOffsetsResponse
* @throws TencentCloudSDKException
*/
public BatchModifyGroupOffsetsResponse BatchModifyGroupOffsets(BatchModifyGroupOffsetsRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "BatchModifyGroupOffsets", BatchModifyGroupOffsetsResponse.class);
}
/**
*批量设置主题属性
* @param req BatchModifyTopicAttributesRequest
* @return BatchModifyTopicAttributesResponse
* @throws TencentCloudSDKException
*/
public BatchModifyTopicAttributesResponse BatchModifyTopicAttributes(BatchModifyTopicAttributesRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "BatchModifyTopicAttributes", BatchModifyTopicAttributesResponse.class);
}
/**
*取消授权token
* @param req CancelAuthorizationTokenRequest
* @return CancelAuthorizationTokenResponse
* @throws TencentCloudSDKException
*/
public CancelAuthorizationTokenResponse CancelAuthorizationToken(CancelAuthorizationTokenRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "CancelAuthorizationToken", CancelAuthorizationTokenResponse.class);
}
/**
*用于查询cdc-ckafka任务状态
* @param req CheckCdcClusterRequest
* @return CheckCdcClusterResponse
* @throws TencentCloudSDKException
*/
public CheckCdcClusterResponse CheckCdcCluster(CheckCdcClusterRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "CheckCdcCluster", CheckCdcClusterResponse.class);
}
/**
*添加 ACL 策略
* @param req CreateAclRequest
* @return CreateAclResponse
* @throws TencentCloudSDKException
*/
public CreateAclResponse CreateAcl(CreateAclRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "CreateAcl", CreateAclResponse.class);
}
/**
*添加 ACL 规则
* @param req CreateAclRuleRequest
* @return CreateAclRuleResponse
* @throws TencentCloudSDKException
*/
public CreateAclRuleResponse CreateAclRule(CreateAclRuleRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "CreateAclRule", CreateAclRuleResponse.class);
}
/**
*用于cdc的专用ckafka集群
* @param req CreateCdcClusterRequest
* @return CreateCdcClusterResponse
* @throws TencentCloudSDKException
*/
public CreateCdcClusterResponse CreateCdcCluster(CreateCdcClusterRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "CreateCdcCluster", CreateCdcClusterResponse.class);
}
/**
*创建Datahub连接源
* @param req CreateConnectResourceRequest
* @return CreateConnectResourceResponse
* @throws TencentCloudSDKException
*/
public CreateConnectResourceResponse CreateConnectResource(CreateConnectResourceRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "CreateConnectResource", CreateConnectResourceResponse.class);
}
/**
*创建消费者组
* @param req CreateConsumerRequest
* @return CreateConsumerResponse
* @throws TencentCloudSDKException
*/
public CreateConsumerResponse CreateConsumer(CreateConsumerRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "CreateConsumer", CreateConsumerResponse.class);
}
/**
*创建DIP转储任务
* @param req CreateDatahubTaskRequest
* @return CreateDatahubTaskResponse
* @throws TencentCloudSDKException
*/
public CreateDatahubTaskResponse CreateDatahubTask(CreateDatahubTaskRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "CreateDatahubTask", CreateDatahubTaskResponse.class);
}
/**
*创建DIP主题
* @param req CreateDatahubTopicRequest
* @return CreateDatahubTopicResponse
* @throws TencentCloudSDKException
*/
public CreateDatahubTopicResponse CreateDatahubTopic(CreateDatahubTopicRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "CreateDatahubTopic", CreateDatahubTopicResponse.class);
}
/**
*由于出参需要更新,当前接口将会在未来版本中废弃,建议用户迁移使用 CreatePostPaidInstance 接口。创建按量计费实例。通常用于 SDK 或云 API 控制台调用接口,创建后付费 CKafka 实例。调用接口与在 CKafka 控制台购买按量付费实例效果相同。
* @param req CreateInstancePostRequest
* @return CreateInstancePostResponse
* @throws TencentCloudSDKException
*/
public CreateInstancePostResponse CreateInstancePost(CreateInstancePostRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "CreateInstancePost", CreateInstancePostResponse.class);
}
/**
*创建实例(预付费包年包月), 仅支持创建专业版实例
* @param req CreateInstancePreRequest
* @return CreateInstancePreResponse
* @throws TencentCloudSDKException
*/
public CreateInstancePreResponse CreateInstancePre(CreateInstancePreRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "CreateInstancePre", CreateInstancePreResponse.class);
}
/**
*本接口用于增加主题中的分区
* @param req CreatePartitionRequest
* @return CreatePartitionResponse
* @throws TencentCloudSDKException
*/
public CreatePartitionResponse CreatePartition(CreatePartitionRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "CreatePartition", CreatePartitionResponse.class);
}
/**
*当前接口用来替代 CreateInstancePost 接口。创建按量计费实例。通常用于 SDK 或云 API 控制台调用接口,创建后付费 CKafka 实例。调用接口与在 CKafka 控制台购买按量付费实例效果相同。
* @param req CreatePostPaidInstanceRequest
* @return CreatePostPaidInstanceResponse
* @throws TencentCloudSDKException
*/
public CreatePostPaidInstanceResponse CreatePostPaidInstance(CreatePostPaidInstanceRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "CreatePostPaidInstance", CreatePostPaidInstanceResponse.class);
}
/**
*添加普罗米修斯监控1
* @param req CreatePrometheusRequest
* @return CreatePrometheusResponse
* @throws TencentCloudSDKException
*/
public CreatePrometheusResponse CreatePrometheus(CreatePrometheusRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "CreatePrometheus", CreatePrometheusResponse.class);
}
/**
*添加实例路由
* @param req CreateRouteRequest
* @return CreateRouteResponse
* @throws TencentCloudSDKException
*/
public CreateRouteResponse CreateRoute(CreateRouteRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "CreateRoute", CreateRouteResponse.class);
}
/**
*创建最高权限的token
* @param req CreateTokenRequest
* @return CreateTokenResponse
* @throws TencentCloudSDKException
*/
public CreateTokenResponse CreateToken(CreateTokenRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "CreateToken", CreateTokenResponse.class);
}
/**
*创建ckafka主题
* @param req CreateTopicRequest
* @return CreateTopicResponse
* @throws TencentCloudSDKException
*/
public CreateTopicResponse CreateTopic(CreateTopicRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "CreateTopic", CreateTopicResponse.class);
}
/**
*创建主题ip白名单
* @param req CreateTopicIpWhiteListRequest
* @return CreateTopicIpWhiteListResponse
* @throws TencentCloudSDKException
*/
public CreateTopicIpWhiteListResponse CreateTopicIpWhiteList(CreateTopicIpWhiteListRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "CreateTopicIpWhiteList", CreateTopicIpWhiteListResponse.class);
}
/**
*添加用户
* @param req CreateUserRequest
* @return CreateUserResponse
* @throws TencentCloudSDKException
*/
public CreateUserResponse CreateUser(CreateUserRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "CreateUser", CreateUserResponse.class);
}
/**
*删除ACL
* @param req DeleteAclRequest
* @return DeleteAclResponse
* @throws TencentCloudSDKException
*/
public DeleteAclResponse DeleteAcl(DeleteAclRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DeleteAcl", DeleteAclResponse.class);
}
/**
*删除ACL规则
* @param req DeleteAclRuleRequest
* @return DeleteAclRuleResponse
* @throws TencentCloudSDKException
*/
public DeleteAclRuleResponse DeleteAclRule(DeleteAclRuleRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DeleteAclRule", DeleteAclRuleResponse.class);
}
/**
*删除Datahub连接源
* @param req DeleteConnectResourceRequest
* @return DeleteConnectResourceResponse
* @throws TencentCloudSDKException
*/
public DeleteConnectResourceResponse DeleteConnectResource(DeleteConnectResourceRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DeleteConnectResource", DeleteConnectResourceResponse.class);
}
/**
*删除Dip任务
* @param req DeleteDatahubTaskRequest
* @return DeleteDatahubTaskResponse
* @throws TencentCloudSDKException
*/
public DeleteDatahubTaskResponse DeleteDatahubTask(DeleteDatahubTaskRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DeleteDatahubTask", DeleteDatahubTaskResponse.class);
}
/**
*删除Datahub主题
* @param req DeleteDatahubTopicRequest
* @return DeleteDatahubTopicResponse
* @throws TencentCloudSDKException
*/
public DeleteDatahubTopicResponse DeleteDatahubTopic(DeleteDatahubTopicRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DeleteDatahubTopic", DeleteDatahubTopicResponse.class);
}
/**
*删除消费组
* @param req DeleteGroupRequest
* @return DeleteGroupResponse
* @throws TencentCloudSDKException
*/
public DeleteGroupResponse DeleteGroup(DeleteGroupRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DeleteGroup", DeleteGroupResponse.class);
}
/**
*删除后付费实例
* @param req DeleteInstancePostRequest
* @return DeleteInstancePostResponse
* @throws TencentCloudSDKException
*/
public DeleteInstancePostResponse DeleteInstancePost(DeleteInstancePostRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DeleteInstancePost", DeleteInstancePostResponse.class);
}
/**
*删除预付费实例
* @param req DeleteInstancePreRequest
* @return DeleteInstancePreResponse
* @throws TencentCloudSDKException
*/
public DeleteInstancePreResponse DeleteInstancePre(DeleteInstancePreRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DeleteInstancePre", DeleteInstancePreResponse.class);
}
/**
*删除路由
* @param req DeleteRouteRequest
* @return DeleteRouteResponse
* @throws TencentCloudSDKException
*/
public DeleteRouteResponse DeleteRoute(DeleteRouteRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DeleteRoute", DeleteRouteResponse.class);
}
/**
*修改删除路由延迟触发时间
* @param req DeleteRouteTriggerTimeRequest
* @return DeleteRouteTriggerTimeResponse
* @throws TencentCloudSDKException
*/
public DeleteRouteTriggerTimeResponse DeleteRouteTriggerTime(DeleteRouteTriggerTimeRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DeleteRouteTriggerTime", DeleteRouteTriggerTimeResponse.class);
}
/**
*删除ckafka主题
* @param req DeleteTopicRequest
* @return DeleteTopicResponse
* @throws TencentCloudSDKException
*/
public DeleteTopicResponse DeleteTopic(DeleteTopicRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DeleteTopic", DeleteTopicResponse.class);
}
/**
*删除主题IP白名单
* @param req DeleteTopicIpWhiteListRequest
* @return DeleteTopicIpWhiteListResponse
* @throws TencentCloudSDKException
*/
public DeleteTopicIpWhiteListResponse DeleteTopicIpWhiteList(DeleteTopicIpWhiteListRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DeleteTopicIpWhiteList", DeleteTopicIpWhiteListResponse.class);
}
/**
*删除用户
* @param req DeleteUserRequest
* @return DeleteUserResponse
* @throws TencentCloudSDKException
*/
public DeleteUserResponse DeleteUser(DeleteUserRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DeleteUser", DeleteUserResponse.class);
}
/**
*枚举ACL
* @param req DescribeACLRequest
* @return DescribeACLResponse
* @throws TencentCloudSDKException
*/
public DescribeACLResponse DescribeACL(DescribeACLRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DescribeACL", DescribeACLResponse.class);
}
/**
*查询ACL规则列表
* @param req DescribeAclRuleRequest
* @return DescribeAclRuleResponse
* @throws TencentCloudSDKException
*/
public DescribeAclRuleResponse DescribeAclRule(DescribeAclRuleRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DescribeAclRule", DescribeAclRuleResponse.class);
}
/**
*查询用户列表
* @param req DescribeAppInfoRequest
* @return DescribeAppInfoResponse
* @throws TencentCloudSDKException
*/
public DescribeAppInfoResponse DescribeAppInfo(DescribeAppInfoRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DescribeAppInfo", DescribeAppInfoResponse.class);
}
/**
*用于查看ckafka的可用区列表
* @param req DescribeCkafkaZoneRequest
* @return DescribeCkafkaZoneResponse
* @throws TencentCloudSDKException
*/
public DescribeCkafkaZoneResponse DescribeCkafkaZone(DescribeCkafkaZoneRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DescribeCkafkaZone", DescribeCkafkaZoneResponse.class);
}
/**
*查询Datahub连接源
* @param req DescribeConnectResourceRequest
* @return DescribeConnectResourceResponse
* @throws TencentCloudSDKException
*/
public DescribeConnectResourceResponse DescribeConnectResource(DescribeConnectResourceRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DescribeConnectResource", DescribeConnectResourceResponse.class);
}
/**
*查询Datahub连接源列表
* @param req DescribeConnectResourcesRequest
* @return DescribeConnectResourcesResponse
* @throws TencentCloudSDKException
*/
public DescribeConnectResourcesResponse DescribeConnectResources(DescribeConnectResourcesRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DescribeConnectResources", DescribeConnectResourcesResponse.class);
}
/**
*查询消费分组信息
* @param req DescribeConsumerGroupRequest
* @return DescribeConsumerGroupResponse
* @throws TencentCloudSDKException
*/
public DescribeConsumerGroupResponse DescribeConsumerGroup(DescribeConsumerGroupRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DescribeConsumerGroup", DescribeConsumerGroupResponse.class);
}
/**
*获取Datahub消费分组offset
* @param req DescribeDatahubGroupOffsetsRequest
* @return DescribeDatahubGroupOffsetsResponse
* @throws TencentCloudSDKException
*/
public DescribeDatahubGroupOffsetsResponse DescribeDatahubGroupOffsets(DescribeDatahubGroupOffsetsRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DescribeDatahubGroupOffsets", DescribeDatahubGroupOffsetsResponse.class);
}
/**
*查询Datahub任务信息
* @param req DescribeDatahubTaskRequest
* @return DescribeDatahubTaskResponse
* @throws TencentCloudSDKException
*/
public DescribeDatahubTaskResponse DescribeDatahubTask(DescribeDatahubTaskRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DescribeDatahubTask", DescribeDatahubTaskResponse.class);
}
/**
*查询Datahub任务列表
* @param req DescribeDatahubTasksRequest
* @return DescribeDatahubTasksResponse
* @throws TencentCloudSDKException
*/
public DescribeDatahubTasksResponse DescribeDatahubTasks(DescribeDatahubTasksRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DescribeDatahubTasks", DescribeDatahubTasksResponse.class);
}
/**
*获取DIP主题属性
* @param req DescribeDatahubTopicRequest
* @return DescribeDatahubTopicResponse
* @throws TencentCloudSDKException
*/
public DescribeDatahubTopicResponse DescribeDatahubTopic(DescribeDatahubTopicRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DescribeDatahubTopic", DescribeDatahubTopicResponse.class);
}
/**
*查询DIP主题列表
* @param req DescribeDatahubTopicsRequest
* @return DescribeDatahubTopicsResponse
* @throws TencentCloudSDKException
*/
public DescribeDatahubTopicsResponse DescribeDatahubTopics(DescribeDatahubTopicsRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DescribeDatahubTopics", DescribeDatahubTopicsResponse.class);
}
/**
*枚举消费分组(精简版)
* @param req DescribeGroupRequest
* @return DescribeGroupResponse
* @throws TencentCloudSDKException
*/
public DescribeGroupResponse DescribeGroup(DescribeGroupRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DescribeGroup", DescribeGroupResponse.class);
}
/**
*获取消费分组信息
* @param req DescribeGroupInfoRequest
* @return DescribeGroupInfoResponse
* @throws TencentCloudSDKException
*/
public DescribeGroupInfoResponse DescribeGroupInfo(DescribeGroupInfoRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DescribeGroupInfo", DescribeGroupInfoResponse.class);
}
/**
*获取消费分组offset
* @param req DescribeGroupOffsetsRequest
* @return DescribeGroupOffsetsResponse
* @throws TencentCloudSDKException
*/
public DescribeGroupOffsetsResponse DescribeGroupOffsets(DescribeGroupOffsetsRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DescribeGroupOffsets", DescribeGroupOffsetsResponse.class);
}
/**
*获取实例属性
* @param req DescribeInstanceAttributesRequest
* @return DescribeInstanceAttributesResponse
* @throws TencentCloudSDKException
*/
public DescribeInstanceAttributesResponse DescribeInstanceAttributes(DescribeInstanceAttributesRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DescribeInstanceAttributes", DescribeInstanceAttributesResponse.class);
}
/**
*本接口(DescribeInstance)用于在用户账户下获取消息队列 CKafka 实例列表
* @param req DescribeInstancesRequest
* @return DescribeInstancesResponse
* @throws TencentCloudSDKException
*/
public DescribeInstancesResponse DescribeInstances(DescribeInstancesRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DescribeInstances", DescribeInstancesResponse.class);
}
/**
*用户账户下获取实例列表详情
* @param req DescribeInstancesDetailRequest
* @return DescribeInstancesDetailResponse
* @throws TencentCloudSDKException
*/
public DescribeInstancesDetailResponse DescribeInstancesDetail(DescribeInstancesDetailRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DescribeInstancesDetail", DescribeInstancesDetailResponse.class);
}
/**
*获取实例Prometheus信息
* @param req DescribePrometheusRequest
* @return DescribePrometheusResponse
* @throws TencentCloudSDKException
*/
public DescribePrometheusResponse DescribePrometheus(DescribePrometheusRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DescribePrometheus", DescribePrometheusResponse.class);
}
/**
*枚举地域,只支持广州地域
* @param req DescribeRegionRequest
* @return DescribeRegionResponse
* @throws TencentCloudSDKException
*/
public DescribeRegionResponse DescribeRegion(DescribeRegionRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DescribeRegion", DescribeRegionResponse.class);
}
/**
*查看路由信息
* @param req DescribeRouteRequest
* @return DescribeRouteResponse
* @throws TencentCloudSDKException
*/
public DescribeRouteResponse DescribeRoute(DescribeRouteRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DescribeRoute", DescribeRouteResponse.class);
}
/**
*查询任务状态
* @param req DescribeTaskStatusRequest
* @return DescribeTaskStatusResponse
* @throws TencentCloudSDKException
*/
public DescribeTaskStatusResponse DescribeTaskStatus(DescribeTaskStatusRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DescribeTaskStatus", DescribeTaskStatusResponse.class);
}
/**
*接口请求域名:https://ckafka.tencentcloudapi.com
本接口(DescribeTopic)用于在用户获取消息队列 CKafka 实例的主题列表
* @param req DescribeTopicRequest
* @return DescribeTopicResponse
* @throws TencentCloudSDKException
*/
public DescribeTopicResponse DescribeTopic(DescribeTopicRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DescribeTopic", DescribeTopicResponse.class);
}
/**
*获取主题属性
* @param req DescribeTopicAttributesRequest
* @return DescribeTopicAttributesResponse
* @throws TencentCloudSDKException
*/
public DescribeTopicAttributesResponse DescribeTopicAttributes(DescribeTopicAttributesRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DescribeTopicAttributes", DescribeTopicAttributesResponse.class);
}
/**
*获取主题列表详情(仅控制台调用)
* @param req DescribeTopicDetailRequest
* @return DescribeTopicDetailResponse
* @throws TencentCloudSDKException
*/
public DescribeTopicDetailResponse DescribeTopicDetail(DescribeTopicDetailRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DescribeTopicDetail", DescribeTopicDetailResponse.class);
}
/**
*获取Topic流量排行,消费者流量排行
* @param req DescribeTopicFlowRankingRequest
* @return DescribeTopicFlowRankingResponse
* @throws TencentCloudSDKException
*/
public DescribeTopicFlowRankingResponse DescribeTopicFlowRanking(DescribeTopicFlowRankingRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DescribeTopicFlowRanking", DescribeTopicFlowRankingResponse.class);
}
/**
*查询topic 生产端连接信息
* @param req DescribeTopicProduceConnectionRequest
* @return DescribeTopicProduceConnectionResponse
* @throws TencentCloudSDKException
*/
public DescribeTopicProduceConnectionResponse DescribeTopicProduceConnection(DescribeTopicProduceConnectionRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DescribeTopicProduceConnection", DescribeTopicProduceConnectionResponse.class);
}
/**
*查询订阅某主题消息分组信息
* @param req DescribeTopicSubscribeGroupRequest
* @return DescribeTopicSubscribeGroupResponse
* @throws TencentCloudSDKException
*/
public DescribeTopicSubscribeGroupResponse DescribeTopicSubscribeGroup(DescribeTopicSubscribeGroupRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DescribeTopicSubscribeGroup", DescribeTopicSubscribeGroupResponse.class);
}
/**
*获取Topic 副本详情信息
* @param req DescribeTopicSyncReplicaRequest
* @return DescribeTopicSyncReplicaResponse
* @throws TencentCloudSDKException
*/
public DescribeTopicSyncReplicaResponse DescribeTopicSyncReplica(DescribeTopicSyncReplicaRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DescribeTopicSyncReplica", DescribeTopicSyncReplicaResponse.class);
}
/**
*查询用户信息
* @param req DescribeUserRequest
* @return DescribeUserResponse
* @throws TencentCloudSDKException
*/
public DescribeUserResponse DescribeUser(DescribeUserRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "DescribeUser", DescribeUserResponse.class);
}
/**
*根据指定offset位置的消息
* @param req FetchDatahubMessageByOffsetRequest
* @return FetchDatahubMessageByOffsetResponse
* @throws TencentCloudSDKException
*/
public FetchDatahubMessageByOffsetResponse FetchDatahubMessageByOffset(FetchDatahubMessageByOffsetRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "FetchDatahubMessageByOffset", FetchDatahubMessageByOffsetResponse.class);
}
/**
*查询最新消息列表
* @param req FetchLatestDatahubMessageListRequest
* @return FetchLatestDatahubMessageListResponse
* @throws TencentCloudSDKException
*/
public FetchLatestDatahubMessageListResponse FetchLatestDatahubMessageList(FetchLatestDatahubMessageListRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "FetchLatestDatahubMessageList", FetchLatestDatahubMessageListResponse.class);
}
/**
*根据指定offset位置的消息
* @param req FetchMessageByOffsetRequest
* @return FetchMessageByOffsetResponse
* @throws TencentCloudSDKException
*/
public FetchMessageByOffsetResponse FetchMessageByOffset(FetchMessageByOffsetRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "FetchMessageByOffset", FetchMessageByOffsetResponse.class);
}
/**
*根据位点查询消息列表
* @param req FetchMessageListByOffsetRequest
* @return FetchMessageListByOffsetResponse
* @throws TencentCloudSDKException
*/
public FetchMessageListByOffsetResponse FetchMessageListByOffset(FetchMessageListByOffsetRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "FetchMessageListByOffset", FetchMessageListByOffsetResponse.class);
}
/**
*Ckafka实例购买/续费询价
* @param req InquireCkafkaPriceRequest
* @return InquireCkafkaPriceResponse
* @throws TencentCloudSDKException
*/
public InquireCkafkaPriceResponse InquireCkafkaPrice(InquireCkafkaPriceRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "InquireCkafkaPrice", InquireCkafkaPriceResponse.class);
}
/**
*按量实例缩容
* @param req InstanceScalingDownRequest
* @return InstanceScalingDownResponse
* @throws TencentCloudSDKException
*/
public InstanceScalingDownResponse InstanceScalingDown(InstanceScalingDownRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "InstanceScalingDown", InstanceScalingDownResponse.class);
}
/**
*修改ACL策略,目前只支持预设规则的是否应用到新增topic这一项的修改
* @param req ModifyAclRuleRequest
* @return ModifyAclRuleResponse
* @throws TencentCloudSDKException
*/
public ModifyAclRuleResponse ModifyAclRule(ModifyAclRuleRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "ModifyAclRule", ModifyAclRuleResponse.class);
}
/**
*编辑Datahub连接源
* @param req ModifyConnectResourceRequest
* @return ModifyConnectResourceResponse
* @throws TencentCloudSDKException
*/
public ModifyConnectResourceResponse ModifyConnectResource(ModifyConnectResourceRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "ModifyConnectResource", ModifyConnectResourceResponse.class);
}
/**
*修改Datahub任务
* @param req ModifyDatahubTaskRequest
* @return ModifyDatahubTaskResponse
* @throws TencentCloudSDKException
*/
public ModifyDatahubTaskResponse ModifyDatahubTask(ModifyDatahubTaskRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "ModifyDatahubTask", ModifyDatahubTaskResponse.class);
}
/**
*修改DIP主题属性
* @param req ModifyDatahubTopicRequest
* @return ModifyDatahubTopicResponse
* @throws TencentCloudSDKException
*/
public ModifyDatahubTopicResponse ModifyDatahubTopic(ModifyDatahubTopicRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "ModifyDatahubTopic", ModifyDatahubTopicResponse.class);
}
/**
*设置Groups 消费分组offset
* @param req ModifyGroupOffsetsRequest
* @return ModifyGroupOffsetsResponse
* @throws TencentCloudSDKException
*/
public ModifyGroupOffsetsResponse ModifyGroupOffsets(ModifyGroupOffsetsRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "ModifyGroupOffsets", ModifyGroupOffsetsResponse.class);
}
/**
*设置实例属性
* @param req ModifyInstanceAttributesRequest
* @return ModifyInstanceAttributesResponse
* @throws TencentCloudSDKException
*/
public ModifyInstanceAttributesResponse ModifyInstanceAttributes(ModifyInstanceAttributesRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "ModifyInstanceAttributes", ModifyInstanceAttributesResponse.class);
}
/**
*预付费实例变配接口,调整磁盘,带宽
* @param req ModifyInstancePreRequest
* @return ModifyInstancePreResponse
* @throws TencentCloudSDKException
*/
public ModifyInstancePreResponse ModifyInstancePre(ModifyInstancePreRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "ModifyInstancePre", ModifyInstancePreResponse.class);
}
/**
*修改密码
* @param req ModifyPasswordRequest
* @return ModifyPasswordResponse
* @throws TencentCloudSDKException
*/
public ModifyPasswordResponse ModifyPassword(ModifyPasswordRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "ModifyPassword", ModifyPasswordResponse.class);
}
/**
*本接口用于修改主题属性。
* @param req ModifyTopicAttributesRequest
* @return ModifyTopicAttributesResponse
* @throws TencentCloudSDKException
*/
public ModifyTopicAttributesResponse ModifyTopicAttributes(ModifyTopicAttributesRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "ModifyTopicAttributes", ModifyTopicAttributesResponse.class);
}
/**
*续费Ckafka实例, 目前只支持国内站包年包月实例续费
* @param req RenewCkafkaInstanceRequest
* @return RenewCkafkaInstanceResponse
* @throws TencentCloudSDKException
*/
public RenewCkafkaInstanceResponse RenewCkafkaInstance(RenewCkafkaInstanceRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "RenewCkafkaInstance", RenewCkafkaInstanceResponse.class);
}
/**
*通过HTTP接入层发送消息
* @param req SendMessageRequest
* @return SendMessageResponse
* @throws TencentCloudSDKException
*/
public SendMessageResponse SendMessage(SendMessageRequest req) throws TencentCloudSDKException{
req.setSkipSign(false);
return this.internalRequest(req, "SendMessage", SendMessageResponse.class);
}
}