public static class DefaultCouchbaseKafkaEnvironment.Builder
extends com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
Constructor and Description |
---|
Builder() |
autoreleaseAfter, bootstrapCarrierDirectPort, bootstrapCarrierEnabled, bootstrapCarrierSslPort, bootstrapHttpDirectPort, bootstrapHttpEnabled, bootstrapHttpSslPort, bufferPoolingEnabled, callbacksOnIoPool, computationPoolSize, dcpConnectionBufferAckThreshold, dcpConnectionBufferSize, dcpConnectionName, dcpEnabled, defaultMetricsLoggingConsumer, defaultMetricsLoggingConsumer, disconnectTimeout, eventBus, ioPool, ioPool, ioPoolSize, keepAliveInterval, kvEndpoints, maxRequestLifetime, mutationTokensEnabled, networkLatencyMetricsCollectorConfig, observeIntervalDelay, packageNameAndVersion, queryEndpoints, reconnectDelay, requestBufferSize, requestBufferWaitStrategy, responseBufferSize, retryDelay, retryStrategy, runtimeMetricsCollectorConfig, scheduler, scheduler, searchEndpoints, socketConnectTimeout, sslEnabled, sslKeystore, sslKeystoreFile, sslKeystorePassword, tcpNodelayEnabled, userAgent, viewEndpoints
public DefaultCouchbaseKafkaEnvironment.Builder kafkaValueSerializerClass(String className)
public DefaultCouchbaseKafkaEnvironment.Builder kafkaKeySerializerClass(String className)
public DefaultCouchbaseKafkaEnvironment.Builder kafkaFilterClass(String className)
public DefaultCouchbaseKafkaEnvironment.Builder kafkaEventBufferSize(int eventBufferSize)
public DefaultCouchbaseKafkaEnvironment.Builder kafkaTopic(String kafkaTopic)
public DefaultCouchbaseKafkaEnvironment.Builder kafkaZookeeperAddress(String kafkaZookeeperAddress)
public DefaultCouchbaseKafkaEnvironment.Builder couchbaseStateSerializerClass(String couchbaseStateSerializerClass)
public DefaultCouchbaseKafkaEnvironment.Builder couchbaseStateSerializationThreshold(long couchbaseStateSerializationThreshold)
public DefaultCouchbaseKafkaEnvironment.Builder couchbaseNodes(List<String> couchbaseNodes)
public DefaultCouchbaseKafkaEnvironment.Builder couchbaseNodes(String couchbaseNode)
public DefaultCouchbaseKafkaEnvironment.Builder couchbaseBucket(String couchbaseBucket)
public DefaultCouchbaseKafkaEnvironment.Builder couchbasePassword(String couchbasePassword)
public DefaultCouchbaseKafkaEnvironment.Builder connectTimeout(long connectTimeout)
DefaultCouchbaseKafkaEnvironment.CONNECT_TIMEOUT
.public DefaultCouchbaseKafkaEnvironment build()
build
in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
Copyright © 2015 Couchbase, Inc.