public static class CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParametersConnectorParameters
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:
mongo-sink
|
| 构造器和说明 |
|---|
CreateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParametersConnectorParameters() |
@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
mongo-sink
public CreateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParametersConnectorParameters()
public static CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParametersConnectorParameters build(Map<String,?> map) throws Exception
Exceptionpublic CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParametersConnectorParameters setConfig(Map<String,?> config)
public CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParametersConnectorParameters setName(String name)
public String getName()
Copyright © 2026. All rights reserved.