public static class CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceCustomizedKafkaConnectorParametersConnectorParameters
extends com.aliyun.tea.TeaModel
| 限定符和类型 | 字段和说明 |
|---|---|
Map<String,?> |
config
example:
{
"connector.class": "com.mongodb.kafka.connect.MongoSinkConnector",
"tasks.max": "1",
"topics": "sourceA,sourceB"
}
|
String |
name
example:
test-name
|
| 构造器和说明 |
|---|
CreateEventStreamingRequestSourceSourceCustomizedKafkaConnectorParametersConnectorParameters() |
@NameInMap(value="Config") public Map<String,?> config
{ "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector", "tasks.max": "1", "topics": "sourceA,sourceB" }
@NameInMap(value="Name") public String name
test-name
public CreateEventStreamingRequestSourceSourceCustomizedKafkaConnectorParametersConnectorParameters()
public static CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceCustomizedKafkaConnectorParametersConnectorParameters build(Map<String,?> map) throws Exception
Exceptionpublic CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceCustomizedKafkaConnectorParametersConnectorParameters setConfig(Map<String,?> config)
public CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceCustomizedKafkaConnectorParametersConnectorParameters setName(String name)
public String getName()
Copyright © 2026. All rights reserved.