com.aliyun.eventbridge20200401.models

类 GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceCustomizedKafkaConnectorParameters

java.lang.Object

com.aliyun.tea.TeaModel

com.aliyun.eventbridge20200401.models.GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceCustomizedKafkaConnectorParameters

封闭类:

GetEventStreamingResponseBody

public static class GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceCustomizedKafkaConnectorParameters
extends com.aliyun.tea.TeaModel

字段概要

字段

限定符和类型	字段和说明
String	connectorPackageUrl example: "	GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceCustomizedKafkaConnectorParametersConnectorParameters	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" }

构造器概要

构造器

构造器和说明
GetEventStreamingResponseBodyDataSourceSourceCustomizedKafkaConnectorParameters()

方法概要

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

构造器详细资料

GetEventStreamingResponseBodyDataSourceSourceCustomizedKafkaConnectorParameters

public GetEventStreamingResponseBodyDataSourceSourceCustomizedKafkaConnectorParameters()

方法详细资料

build

public static GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceCustomizedKafkaConnectorParameters build(Map<String,?> map)
                                                                                                                           throws Exception

抛出:

Exception

setConnectorPackageUrl

public GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceCustomizedKafkaConnectorParameters setConnectorPackageUrl(String connectorPackageUrl)

getConnectorPackageUrl

public String getConnectorPackageUrl()

setConnectorParameters

public GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceCustomizedKafkaConnectorParameters setConnectorParameters(GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceCustomizedKafkaConnectorParametersConnectorParameters connectorParameters)

getConnectorParameters

public GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceCustomizedKafkaConnectorParametersConnectorParameters getConnectorParameters()

setWorkerParameters

public GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceCustomizedKafkaConnectorParameters setWorkerParameters(Map<String,?> workerParameters)

getWorkerParameters

public Map<String,?> getWorkerParameters()