com.aliyun.eventbridge20200401.models

类 UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParameters

java.lang.Object

com.aliyun.tea.TeaModel

com.aliyun.eventbridge20200401.models.UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParameters

封闭类:

UpdateEventStreamingRequest

public static class UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParameters
extends com.aliyun.tea.TeaModel

字段概要

字段

限定符和类型	字段和说明
String	connectorPackageUrl The download link of the ZIP package that includes Object Storage Service (OSS) resources.
UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParametersConnectorParameters	connectorParameters The parameters that are configured for the parsing of the .properties file in the ZIP package.
Map<String,?>	workerParameters The instance configurations.

构造器概要

构造器

构造器和说明
UpdateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParameters()

方法概要

限定符和类型	方法和说明
static UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParameters	build(Map<String,?> map)
String	getConnectorPackageUrl()
UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParametersConnectorParameters	getConnectorParameters()
Map<String,?>	getWorkerParameters()
UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParameters	setConnectorPackageUrl(String connectorPackageUrl)
UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParameters	setConnectorParameters(UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParametersConnectorParameters connectorParameters)
UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParameters	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

The download link of the ZIP package that includes Object Storage Service (OSS) resources.

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 UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParametersConnectorParameters connectorParameters

The parameters that are configured for the parsing of the .properties file in the ZIP package.

workerParameters

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

The instance configurations.

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" }

构造器详细资料

UpdateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParameters

public UpdateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParameters()

方法详细资料

build

public static UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParameters build(Map<String,?> map)
                                                                                                               throws Exception

抛出:

Exception

setConnectorPackageUrl

public UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParameters setConnectorPackageUrl(String connectorPackageUrl)

getConnectorPackageUrl

public String getConnectorPackageUrl()

setConnectorParameters

public UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParameters setConnectorParameters(UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParametersConnectorParameters connectorParameters)

getConnectorParameters

public UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParametersConnectorParameters getConnectorParameters()

setWorkerParameters

public UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkCustomizedKafkaConnectorParameters setWorkerParameters(Map<String,?> workerParameters)

getWorkerParameters

public Map<String,?> getWorkerParameters()