DefaultCouchbaseKafkaEnvironment.Builder
to customize environment settings.CouchbaseKafkaConnector
instance.DefaultCouchbaseKafkaEnvironment.CONNECT_TIMEOUT
.DefaultCouchbaseKafkaEnvironment.CONNECT_TIMEOUT
.CouchbaseKafkaConnector
is an entry point of the library.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.CouchbaseReader
is in charge of accepting events from Couchbase.CouchbaseReader
.CouchbaseReader
.CouchbaseKafkaConnector
with default settings.CouchbaseKafkaConnector
with specified settings.CouchbaseKafkaConnector
with specified settings.CouchbaseKafkaEnvironment
to initialize connector settings.CouchbaseKafkaEnvironment
with default settings applied.CouchbaseMessage
and associated information.DCPEvent
s.JsonEncoder
converts events from Couchbase to JSON.KafkaWriter
is in charge of filtering and routing events to the Kafka cluster.KafkaWriter
.KafkaWriter
.MutationsFilter
allows only mutations to be sent to Kafka.DCPEvent
s that come into the response RingBuffer.ConnectorState
is being updated.DCPEvent
to JSON object.Copyright © 2015 Couchbase, Inc.