public interface CouchbaseKafkaEnvironment
extends com.couchbase.client.core.env.CoreEnvironment
CouchbaseKafkaEnvironment
settings related to Kafka connection, in addition to all the core building blocks
like environment settings and thread pools inherited from CoreEnvironment
so
that the application can work with it properly.
This interface defines the contract. How properties are loaded is chosen by the implementation. See the
DefaultCouchbaseKafkaEnvironment
class for the default implementation.
Note that the CouchbaseKafkaEnvironment
is stateful, so be sure to call CoreEnvironment.shutdown()
properly.Modifier and Type | Method and Description |
---|---|
long |
connectTimeout()
The default timeout for connect operations, set to
DefaultCouchbaseKafkaEnvironment.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.
|
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.
|
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
String kafkaValueSerializerClass()
Encoder
parametrized with DCPEvent.String kafkaKeySerializerClass()
Encoder
parametrized with String.String kafkaFilterClass()
Filter
.int kafkaEventBufferSize()
String couchbaseStateSerializerClass()
StateSerializer
.long couchbaseStateSerializationThreshold()
List<String> couchbaseNodes()
String couchbaseBucket()
String couchbasePassword()
String kafkaZookeeperAddress()
String kafkaTopic()
long connectTimeout()
DefaultCouchbaseKafkaEnvironment.CONNECT_TIMEOUT
.Copyright © 2015 Couchbase, Inc.