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