public class DefaultCouchbaseKafkaEnvironment extends com.couchbase.client.core.env.DefaultCoreEnvironment implements CouchbaseKafkaEnvironment
Modifier and Type | Class and Description |
---|---|
static class |
DefaultCouchbaseKafkaEnvironment.Builder |
Modifier and Type | Field and Description |
---|---|
static String |
SDK_PACKAGE_NAME_AND_VERSION |
AUTORELEASE_AFTER, BOOTSTRAP_CARRIER_DIRECT_PORT, BOOTSTRAP_CARRIER_ENABLED, BOOTSTRAP_CARRIER_SSL_PORT, BOOTSTRAP_HTTP_DIRECT_PORT, BOOTSTRAP_HTTP_ENABLED, BOOTSTRAP_HTTP_SSL_PORT, BUFFER_POOLING_ENABLED, CALLBACKS_ON_IO_POOL, COMPUTATION_POOL_SIZE, CORE_GIT_VERSION, CORE_VERSION, DCP_CONNECTION_BUFFER_ACK_THRESHOLD, DCP_CONNECTION_BUFFER_SIZE, DCP_CONNECTION_NAME, DCP_ENABLED, DISCONNECT_TIMEOUT, IO_POOL_SIZE, KEEPALIVEINTERVAL, KEYVALUE_ENDPOINTS, MAX_REQUEST_LIFETIME, MUTATION_TOKENS_ENABLED, OBSERVE_INTERVAL_DELAY, PACKAGE_NAME_AND_VERSION, QUERY_ENDPOINTS, RECONNECT_DELAY, REQUEST_BUFFER_SIZE, RESPONSE_BUFFER_SIZE, RETRY_DELAY, RETRY_STRATEGY, SEARCH_ENDPOINTS, SOCKET_CONNECT_TIMEOUT, SSL_ENABLED, SSL_KEYSTORE, SSL_KEYSTORE_FILE, SSL_KEYSTORE_PASSWORD, TCP_NODELAY_ENALED, USER_AGENT, VIEW_ENDPOINTS
Modifier | Constructor and Description |
---|---|
protected |
DefaultCouchbaseKafkaEnvironment(DefaultCouchbaseKafkaEnvironment.Builder builder) |
Modifier and Type | Method and Description |
---|---|
static DefaultCouchbaseKafkaEnvironment.Builder |
builder()
Returns the
DefaultCouchbaseKafkaEnvironment.Builder to customize environment settings. |
long |
connectTimeout()
The default timeout for connect operations, set to
CONNECT_TIMEOUT . |
String |
couchbaseBucket()
Name of the bucket in Couchbase.
|
List<String> |
couchbaseNodes()
List of Couchbase nodes used to connect.
|
String |
couchbasePassword()
Password if the bucket is protected.
|
long |
couchbaseStateSerializationThreshold()
Minimum time between dumping the state
|
String |
couchbaseStateSerializerClass()
Full name of class used to serialize state of the Couchbase streams.
|
static DefaultCouchbaseKafkaEnvironment |
create()
Creates a
CouchbaseKafkaEnvironment with default settings applied. |
protected StringBuilder |
dumpParameters(StringBuilder sb) |
int |
kafkaEventBufferSize()
Returns the size of the events ringbuffer.
|
String |
kafkaFilterClass()
Full name of class used to filter data stream from Couchbase.
|
String |
kafkaKeySerializerClass()
Full name of class used to encode object keys to byte[] to store in Kafka.
|
String |
kafkaTopic()
Kafka topic to post events.
|
String |
kafkaValueSerializerClass()
Full name of class used to encode objects to byte[] to store in Kafka.
|
String |
kafkaZookeeperAddress()
Zookeeper address to pass into kafka client.
|
String |
toString() |
autoreleaseAfter, booleanPropertyOr, bootstrapCarrierDirectPort, bootstrapCarrierEnabled, bootstrapCarrierSslPort, bootstrapHttpDirectPort, bootstrapHttpEnabled, bootstrapHttpSslPort, bufferPoolingEnabled, callbacksOnIoPool, computationPoolSize, coreBuild, coreVersion, dcpConnectionBufferAckThreshold, dcpConnectionBufferSize, dcpConnectionName, dcpEnabled, disconnectTimeout, doublePropertyOr, eventBus, intPropertyOr, ioPool, ioPoolSize, keepAliveInterval, kvEndpoints, longPropertyOr, maxRequestLifetime, mutationTokensEnabled, networkLatencyMetricsCollector, observeIntervalDelay, packageNameAndVersion, queryEndpoints, reconnectDelay, requestBufferSize, requestBufferWaitStrategy, responseBufferSize, retryDelay, retryStrategy, runtimeMetricsCollector, scheduler, searchEndpoints, shutdown, shutdown, shutdownAsync, socketConnectTimeout, sslEnabled, sslKeystore, sslKeystoreFile, sslKeystorePassword, stringPropertyOr, tcpNodelayEnabled, userAgent, viewEndpoints
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
autoreleaseAfter, bootstrapCarrierDirectPort, bootstrapCarrierEnabled, bootstrapCarrierSslPort, bootstrapHttpDirectPort, bootstrapHttpEnabled, bootstrapHttpSslPort, bufferPoolingEnabled, callbacksOnIoPool, computationPoolSize, coreBuild, coreVersion, dcpConnectionBufferAckThreshold, dcpConnectionBufferSize, dcpConnectionName, dcpEnabled, disconnectTimeout, eventBus, ioPool, ioPoolSize, keepAliveInterval, kvEndpoints, maxRequestLifetime, mutationTokensEnabled, networkLatencyMetricsCollector, observeIntervalDelay, packageNameAndVersion, queryEndpoints, reconnectDelay, requestBufferSize, requestBufferWaitStrategy, responseBufferSize, retryDelay, retryStrategy, runtimeMetricsCollector, scheduler, searchEndpoints, shutdown, shutdown, shutdownAsync, socketConnectTimeout, sslEnabled, sslKeystore, sslKeystoreFile, sslKeystorePassword, tcpNodelayEnabled, userAgent, viewEndpoints
public static String SDK_PACKAGE_NAME_AND_VERSION
protected DefaultCouchbaseKafkaEnvironment(DefaultCouchbaseKafkaEnvironment.Builder builder)
public static DefaultCouchbaseKafkaEnvironment create()
CouchbaseKafkaEnvironment
with default settings applied.DefaultCouchbaseKafkaEnvironment
with default settings.public static DefaultCouchbaseKafkaEnvironment.Builder builder()
DefaultCouchbaseKafkaEnvironment.Builder
to customize environment settings.DefaultCouchbaseKafkaEnvironment.Builder
.public String kafkaValueSerializerClass()
CouchbaseKafkaEnvironment
Encoder
parametrized with DCPEvent.kafkaValueSerializerClass
in interface CouchbaseKafkaEnvironment
public String kafkaKeySerializerClass()
CouchbaseKafkaEnvironment
Encoder
parametrized with String.kafkaKeySerializerClass
in interface CouchbaseKafkaEnvironment
public String kafkaFilterClass()
CouchbaseKafkaEnvironment
Filter
.kafkaFilterClass
in interface CouchbaseKafkaEnvironment
public int kafkaEventBufferSize()
CouchbaseKafkaEnvironment
kafkaEventBufferSize
in interface CouchbaseKafkaEnvironment
public String kafkaZookeeperAddress()
CouchbaseKafkaEnvironment
kafkaZookeeperAddress
in interface CouchbaseKafkaEnvironment
public String kafkaTopic()
CouchbaseKafkaEnvironment
kafkaTopic
in interface CouchbaseKafkaEnvironment
public long connectTimeout()
CouchbaseKafkaEnvironment
CONNECT_TIMEOUT
.connectTimeout
in interface CouchbaseKafkaEnvironment
public long couchbaseStateSerializationThreshold()
CouchbaseKafkaEnvironment
couchbaseStateSerializationThreshold
in interface CouchbaseKafkaEnvironment
public String couchbaseStateSerializerClass()
CouchbaseKafkaEnvironment
StateSerializer
.couchbaseStateSerializerClass
in interface CouchbaseKafkaEnvironment
public List<String> couchbaseNodes()
CouchbaseKafkaEnvironment
couchbaseNodes
in interface CouchbaseKafkaEnvironment
public String couchbaseBucket()
CouchbaseKafkaEnvironment
couchbaseBucket
in interface CouchbaseKafkaEnvironment
public String couchbasePassword()
CouchbaseKafkaEnvironment
couchbasePassword
in interface CouchbaseKafkaEnvironment
protected StringBuilder dumpParameters(StringBuilder sb)
dumpParameters
in class com.couchbase.client.core.env.DefaultCoreEnvironment
public String toString()
toString
in class com.couchbase.client.core.env.DefaultCoreEnvironment
Copyright © 2015 Couchbase, Inc.