com.aliyun.eventbridge20200401.models

类 CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParameters

java.lang.Object

com.aliyun.tea.TeaModel

com.aliyun.eventbridge20200401.models.CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParameters

封闭类:

CreateEventStreamingRequest

public static class CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParameters
extends com.aliyun.tea.TeaModel

字段概要

字段

限定符和类型	字段和说明
String	connectorPackageUrl example: "	CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParametersConnectorParameters	connectorParameters
Map<String,?>	workerParameters example: { "group.id": "connect-eb-cluster-KAFKA_CONNECTORC", "offset.storage.topic": "connect-eb-offset-KAFKA_CONNECTOR_yjqC8K5ewC", "config.storage.topic": "connect-eb-config-KAFKA_CONNECTOR_yjqC8K5ewC", "status.storage.topic": "connect-eb-status-KAFKA_CONNECTOR_yjqC8K5ewC", "consumer.group.id": "connector-eb-cluster-KAFKA_CONNECTOR_yjqC8K5ewC-mongo-sink", "bootstrap.servers": "alikafka-post:9092" }

构造器概要

构造器

构造器和说明
CreateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParameters()

方法概要

限定符和类型	方法和说明
static CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParameters	build(Map<String,?> map)
String	getConnectorPackageUrl()
CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParametersConnectorParameters	getConnectorParameters()
Map<String,?>	getWorkerParameters()
CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParameters	setConnectorPackageUrl(String connectorPackageUrl)
CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParameters	setConnectorParameters(CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParametersConnectorParameters connectorParameters)
CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParameters	setWorkerParameters(Map<String,?> workerParameters)

从类继承的方法 com.aliyun.tea.TeaModel

build, buildMap, confirmType, confirmType, parseObject, toMap, toMap, toModel, validate, validateParams

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

connectorPackageUrl

@NameInMap(value="ConnectorPackageUrl")
public String connectorPackageUrl

example:

"https://examplebucket.oss-cn-hangzhou.aliyuncs.com/testDoc/Old_Homebrew/2024-06-26%2022%3A34%3A08/opt/homebrew/homebrew/Library/Homebrew/test/support/fixtures/cask/AppWithBinary.zip?OSSAccessKeyId=ri&Expires=1725539627&Signature=rb8q3OpV2i3gZJ"

connectorParameters

@NameInMap(value="ConnectorParameters")
public CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParametersConnectorParameters connectorParameters

workerParameters

@NameInMap(value="WorkerParameters")
public Map<String,?> workerParameters

example:

{ "group.id": "connect-eb-cluster-KAFKA_CONNECTORC", "offset.storage.topic": "connect-eb-offset-KAFKA_CONNECTOR_yjqC8K5ewC", "config.storage.topic": "connect-eb-config-KAFKA_CONNECTOR_yjqC8K5ewC", "status.storage.topic": "connect-eb-status-KAFKA_CONNECTOR_yjqC8K5ewC", "consumer.group.id": "connector-eb-cluster-KAFKA_CONNECTOR_yjqC8K5ewC-mongo-sink", "bootstrap.servers": "alikafka-post:9092" }

构造器详细资料

CreateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParameters

public CreateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParameters()

方法详细资料

build

public static CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParameters build(Map<String,?> map)
                                                                                                               throws Exception

抛出:

Exception

setConnectorPackageUrl

public CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParameters setConnectorPackageUrl(String connectorPackageUrl)

getConnectorPackageUrl

public String getConnectorPackageUrl()

setConnectorParameters

public CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParameters setConnectorParameters(CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParametersConnectorParameters connectorParameters)

getConnectorParameters

public CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParametersConnectorParameters getConnectorParameters()

setWorkerParameters

public CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParameters setWorkerParameters(Map<String,?> workerParameters)

getWorkerParameters

public Map<String,?> getWorkerParameters()