Skip navigation links
A B C D E F G I J K L M N O P R S T U V Z 

A

AbstractEncoder - Class in com.couchbase.kafka.coder
Defines base for all encoders of Couchbase events.
AbstractEncoder(VerifiableProperties) - Constructor for class com.couchbase.kafka.coder.AbstractEncoder
 

B

build() - Method in class com.couchbase.kafka.DefaultCouchbaseKafkaEnvironment.Builder
 
builder() - Static method in class com.couchbase.kafka.DefaultCouchbaseKafkaEnvironment
Returns the DefaultCouchbaseKafkaEnvironment.Builder to customize environment settings.
Builder() - Constructor for class com.couchbase.kafka.DefaultCouchbaseKafkaEnvironment.Builder
 

C

clone() - Method in class com.couchbase.kafka.state.ConnectorState
 
com.couchbase.kafka - package com.couchbase.kafka
 
com.couchbase.kafka.coder - package com.couchbase.kafka.coder
 
com.couchbase.kafka.filter - package com.couchbase.kafka.filter
 
com.couchbase.kafka.state - package com.couchbase.kafka.state
 
connect() - Method in class com.couchbase.kafka.CouchbaseReader
Performs connection with default timeout.
connect(long, TimeUnit) - Method in class com.couchbase.kafka.CouchbaseReader
Performs connection with arbitrary timeout
connection() - Method in class com.couchbase.kafka.DCPEvent
Get the associated DCP connection object.
ConnectorState - Class in com.couchbase.kafka.state
Implements state of the @{link CouchbaseKafkaConnector instance.
ConnectorState() - Constructor for class com.couchbase.kafka.state.ConnectorState
 
connectorState() - Method in class com.couchbase.kafka.state.StreamStateUpdatedEvent
 
connectTimeout() - Method in interface com.couchbase.kafka.CouchbaseKafkaEnvironment
The default timeout for connect operations, set to DefaultCouchbaseKafkaEnvironment.CONNECT_TIMEOUT.
connectTimeout(long) - Method in class com.couchbase.kafka.DefaultCouchbaseKafkaEnvironment.Builder
The default timeout for connect operations, set to DefaultCouchbaseKafkaEnvironment.CONNECT_TIMEOUT.
connectTimeout() - Method in class com.couchbase.kafka.DefaultCouchbaseKafkaEnvironment
 
couchbaseBucket() - Method in interface com.couchbase.kafka.CouchbaseKafkaEnvironment
Name of the bucket in Couchbase.
couchbaseBucket(String) - Method in class com.couchbase.kafka.DefaultCouchbaseKafkaEnvironment.Builder
 
couchbaseBucket() - Method in class com.couchbase.kafka.DefaultCouchbaseKafkaEnvironment
 
CouchbaseKafkaConnector - Class in com.couchbase.kafka
CouchbaseKafkaConnector is an entry point of the library.
CouchbaseKafkaEnvironment - Interface in com.couchbase.kafka
A 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.
couchbaseNodes() - Method in interface com.couchbase.kafka.CouchbaseKafkaEnvironment
List of Couchbase nodes used to connect.
couchbaseNodes(List<String>) - Method in class com.couchbase.kafka.DefaultCouchbaseKafkaEnvironment.Builder
 
couchbaseNodes(String) - Method in class com.couchbase.kafka.DefaultCouchbaseKafkaEnvironment.Builder
 
couchbaseNodes() - Method in class com.couchbase.kafka.DefaultCouchbaseKafkaEnvironment
 
couchbasePassword() - Method in interface com.couchbase.kafka.CouchbaseKafkaEnvironment
Password if the bucket is protected.
couchbasePassword(String) - Method in class com.couchbase.kafka.DefaultCouchbaseKafkaEnvironment.Builder
 
couchbasePassword() - Method in class com.couchbase.kafka.DefaultCouchbaseKafkaEnvironment
 
CouchbaseReader - Class in com.couchbase.kafka
CouchbaseReader is in charge of accepting events from Couchbase.
CouchbaseReader(ClusterFacade, CouchbaseKafkaEnvironment, RingBuffer<DCPEvent>, StateSerializer) - Constructor for class com.couchbase.kafka.CouchbaseReader
Creates a new CouchbaseReader.
CouchbaseReader(List<String>, String, String, ClusterFacade, CouchbaseKafkaEnvironment, RingBuffer<DCPEvent>, StateSerializer) - Constructor for class com.couchbase.kafka.CouchbaseReader
Creates a new CouchbaseReader.
couchbaseStateSerializationThreshold() - Method in interface com.couchbase.kafka.CouchbaseKafkaEnvironment
Minimum time between dumping the state
couchbaseStateSerializationThreshold(long) - Method in class com.couchbase.kafka.DefaultCouchbaseKafkaEnvironment.Builder
 
couchbaseStateSerializationThreshold() - Method in class com.couchbase.kafka.DefaultCouchbaseKafkaEnvironment
 
couchbaseStateSerializerClass() - Method in interface com.couchbase.kafka.CouchbaseKafkaEnvironment
Full name of class used to serialize state of the Couchbase streams.
couchbaseStateSerializerClass(String) - Method in class com.couchbase.kafka.DefaultCouchbaseKafkaEnvironment.Builder
 
couchbaseStateSerializerClass() - Method in class com.couchbase.kafka.DefaultCouchbaseKafkaEnvironment
 
create() - Static method in class com.couchbase.kafka.CouchbaseKafkaConnector
Creates CouchbaseKafkaConnector with default settings.
create(CouchbaseKafkaEnvironment) - Static method in class com.couchbase.kafka.CouchbaseKafkaConnector
Create CouchbaseKafkaConnector with specified settings.
create(List<String>, String, String, String, String, CouchbaseKafkaEnvironment) - Static method in class com.couchbase.kafka.CouchbaseKafkaConnector
Create CouchbaseKafkaConnector with specified settings.
create(String, String, String, String, String) - Static method in class com.couchbase.kafka.CouchbaseKafkaConnector
Deprecated.
Use CouchbaseKafkaEnvironment to initialize connector settings.
create() - Static method in class com.couchbase.kafka.DefaultCouchbaseKafkaEnvironment
Creates a CouchbaseKafkaEnvironment with default settings applied.
currentState(int...) - Method in class com.couchbase.kafka.CouchbaseKafkaConnector
Initialize connector state for given partitions with current vbucketUUID and sequence number.
currentState() - Method in class com.couchbase.kafka.CouchbaseReader
Returns current state of the cluster.

D

DCPEvent - Class in com.couchbase.kafka
A pre allocated event which carries a CouchbaseMessage and associated information.
DCPEvent() - Constructor for class com.couchbase.kafka.DCPEvent
 
DCPEventFactory - Class in com.couchbase.kafka
A factory to preallocate DCPEvents.
DCPEventFactory() - Constructor for class com.couchbase.kafka.DCPEventFactory
 
DefaultCouchbaseKafkaEnvironment - Class in com.couchbase.kafka
 
DefaultCouchbaseKafkaEnvironment(DefaultCouchbaseKafkaEnvironment.Builder) - Constructor for class com.couchbase.kafka.DefaultCouchbaseKafkaEnvironment
 
DefaultCouchbaseKafkaEnvironment.Builder - Class in com.couchbase.kafka
 
Direction - Enum in com.couchbase.kafka
 
dump(ConnectorState) - Method in class com.couchbase.kafka.state.NullStateSerializer
 
dump(ConnectorState, short) - Method in class com.couchbase.kafka.state.NullStateSerializer
 
dump(ConnectorState) - Method in interface com.couchbase.kafka.state.StateSerializer
 
dump(ConnectorState, short) - Method in interface com.couchbase.kafka.state.StateSerializer
 
dump(ConnectorState) - Method in class com.couchbase.kafka.state.ZookeeperStateSerializer
 
dump(ConnectorState, short) - Method in class com.couchbase.kafka.state.ZookeeperStateSerializer
 
dumpParameters(StringBuilder) - Method in class com.couchbase.kafka.DefaultCouchbaseKafkaEnvironment
 

E

endState(int...) - Method in class com.couchbase.kafka.CouchbaseKafkaConnector
Initialize connector state for given partitions with current vbucketUUID and maximum sequence number.

F

Filter - Interface in com.couchbase.kafka.filter
General interface to select Couchbase events, which has to be sent to Kafka.

G

get(short) - Method in class com.couchbase.kafka.state.ConnectorState
Returns the stream state.

I

iterator() - Method in class com.couchbase.kafka.state.ConnectorState
 

J

JsonEncoder - Class in com.couchbase.kafka.coder
The JsonEncoder converts events from Couchbase to JSON.
JsonEncoder(VerifiableProperties) - Constructor for class com.couchbase.kafka.coder.JsonEncoder
 

K

kafkaEventBufferSize() - Method in interface com.couchbase.kafka.CouchbaseKafkaEnvironment
Returns the size of the events ringbuffer.
kafkaEventBufferSize(int) - Method in class com.couchbase.kafka.DefaultCouchbaseKafkaEnvironment.Builder
 
kafkaEventBufferSize() - Method in class com.couchbase.kafka.DefaultCouchbaseKafkaEnvironment
 
kafkaFilterClass() - Method in interface com.couchbase.kafka.CouchbaseKafkaEnvironment
Full name of class used to filter data stream from Couchbase.
kafkaFilterClass(String) - Method in class com.couchbase.kafka.DefaultCouchbaseKafkaEnvironment.Builder
 
kafkaFilterClass() - Method in class com.couchbase.kafka.DefaultCouchbaseKafkaEnvironment
 
kafkaKeySerializerClass() - Method in interface com.couchbase.kafka.CouchbaseKafkaEnvironment
Full name of class used to encode object keys to byte[] to store in Kafka.
kafkaKeySerializerClass(String) - Method in class com.couchbase.kafka.DefaultCouchbaseKafkaEnvironment.Builder
 
kafkaKeySerializerClass() - Method in class com.couchbase.kafka.DefaultCouchbaseKafkaEnvironment
 
kafkaTopic() - Method in interface com.couchbase.kafka.CouchbaseKafkaEnvironment
Kafka topic to post events.
kafkaTopic(String) - Method in class com.couchbase.kafka.DefaultCouchbaseKafkaEnvironment.Builder
 
kafkaTopic() - Method in class com.couchbase.kafka.DefaultCouchbaseKafkaEnvironment
 
kafkaValueSerializerClass() - Method in interface com.couchbase.kafka.CouchbaseKafkaEnvironment
Full name of class used to encode objects to byte[] to store in Kafka.
kafkaValueSerializerClass(String) - Method in class com.couchbase.kafka.DefaultCouchbaseKafkaEnvironment.Builder
 
kafkaValueSerializerClass() - Method in class com.couchbase.kafka.DefaultCouchbaseKafkaEnvironment
 
KafkaWriter - Class in com.couchbase.kafka
KafkaWriter is in charge of filtering and routing events to the Kafka cluster.
KafkaWriter(CouchbaseKafkaEnvironment, Producer<String, DCPEvent>, Filter) - Constructor for class com.couchbase.kafka.KafkaWriter
Creates a new KafkaWriter.
KafkaWriter(String, CouchbaseKafkaEnvironment, Producer<String, DCPEvent>, Filter) - Constructor for class com.couchbase.kafka.KafkaWriter
Creates a new KafkaWriter.
kafkaZookeeperAddress() - Method in interface com.couchbase.kafka.CouchbaseKafkaEnvironment
Zookeeper address to pass into kafka client.
kafkaZookeeperAddress(String) - Method in class com.couchbase.kafka.DefaultCouchbaseKafkaEnvironment.Builder
 
kafkaZookeeperAddress() - Method in class com.couchbase.kafka.DefaultCouchbaseKafkaEnvironment
 
key() - Method in class com.couchbase.kafka.DCPEvent
Extract key from the payload.

L

load(ConnectorState) - Method in class com.couchbase.kafka.state.NullStateSerializer
 
load(ConnectorState, short) - Method in class com.couchbase.kafka.state.NullStateSerializer
 
load(ConnectorState) - Method in interface com.couchbase.kafka.state.StateSerializer
 
load(ConnectorState, short) - Method in interface com.couchbase.kafka.state.StateSerializer
 
load(ConnectorState) - Method in class com.couchbase.kafka.state.ZookeeperStateSerializer
 
load(ConnectorState, short) - Method in class com.couchbase.kafka.state.ZookeeperStateSerializer
 
loadState(int...) - Method in class com.couchbase.kafka.CouchbaseKafkaConnector
Initialize connector state for given partitions using configured serializer.

M

message() - Method in class com.couchbase.kafka.DCPEvent
Get the message from the payload.
MutationsFilter - Class in com.couchbase.kafka.filter
The MutationsFilter allows only mutations to be sent to Kafka.
MutationsFilter() - Constructor for class com.couchbase.kafka.filter.MutationsFilter
 

N

newInstance() - Method in class com.couchbase.kafka.DCPEventFactory
 
NullStateSerializer - Class in com.couchbase.kafka.state
Represents serialized which does not persist the state.
NullStateSerializer(CouchbaseKafkaEnvironment) - Constructor for class com.couchbase.kafka.state.NullStateSerializer
 

O

onEvent(DCPEvent, long, boolean) - Method in class com.couchbase.kafka.KafkaWriter
Handles DCPEvents that come into the response RingBuffer.

P

partition() - Method in class com.couchbase.kafka.state.StreamState
The partition number (vBucket), to which this state belongs.
partition() - Method in class com.couchbase.kafka.state.StreamStateUpdatedEvent
 
partitions() - Method in class com.couchbase.kafka.state.ConnectorState
 
pass(DCPEvent) - Method in interface com.couchbase.kafka.filter.Filter
Decides whether dcpEvent should be sent to Kafka.
pass(DCPEvent) - Method in class com.couchbase.kafka.filter.MutationsFilter
Returns true if event is mutation.
put(StreamState) - Method in class com.couchbase.kafka.state.ConnectorState
Set/update the stream state

R

run() - Method in class com.couchbase.kafka.CouchbaseKafkaConnector
Executes worker reading loop, which relays all events from Couchbase to Kafka.
run(ConnectorState, ConnectorState) - Method in class com.couchbase.kafka.CouchbaseKafkaConnector
Executes worker reading loop, which relays events from Couchbase to Kafka in specified range.
run(ConnectorState, ConnectorState) - Method in class com.couchbase.kafka.CouchbaseReader
Executes worker reading loop, which relays events from Couchbase to Kafka.

S

SDK_PACKAGE_NAME_AND_VERSION - Static variable in class com.couchbase.kafka.DefaultCouchbaseKafkaEnvironment
 
sequenceNumber() - Method in class com.couchbase.kafka.state.StreamState
Specified the last by sequence number that has been seen by the consumer.
setConnection(DCPConnection) - Method in class com.couchbase.kafka.DCPEvent
 
setMessage(CouchbaseMessage) - Method in class com.couchbase.kafka.DCPEvent
Set the new message as a payload for this event.
startState(int...) - Method in class com.couchbase.kafka.CouchbaseKafkaConnector
Initialize connector state for given partitions with current vbucketUUID and zero sequence number.
StateSerializer - Interface in com.couchbase.kafka.state
 
StreamState - Class in com.couchbase.kafka.state
This class represents state of DCP stream.
StreamState(MutationToken) - Constructor for class com.couchbase.kafka.state.StreamState
 
StreamState(short, long, long) - Constructor for class com.couchbase.kafka.state.StreamState
 
StreamStateUpdatedEvent - Class in com.couchbase.kafka.state
This event generated when ConnectorState is being updated.
StreamStateUpdatedEvent(ConnectorState, short) - Constructor for class com.couchbase.kafka.state.StreamStateUpdatedEvent
 

T

toBytes(DCPEvent) - Method in class com.couchbase.kafka.coder.AbstractEncoder
Serializes dcpEvent to stream of bytes.
toBytes(DCPEvent) - Method in class com.couchbase.kafka.coder.JsonEncoder
Encodes DCPEvent to JSON object.
toString() - Method in class com.couchbase.kafka.DefaultCouchbaseKafkaEnvironment
 

U

update(short, long) - Method in class com.couchbase.kafka.state.ConnectorState
 
updates() - Method in class com.couchbase.kafka.state.ConnectorState
 

V

valueOf(String) - Static method in enum com.couchbase.kafka.Direction
Returns the enum constant of this type with the specified name.
values() - Static method in enum com.couchbase.kafka.Direction
Returns an array containing the constants of this enum type, in the order they are declared.
vbucketUUID() - Method in class com.couchbase.kafka.state.StreamState
A unique identifier that is generated that is assigned to each VBucket.

Z

ZookeeperStateSerializer - Class in com.couchbase.kafka.state
 
ZookeeperStateSerializer(CouchbaseKafkaEnvironment) - Constructor for class com.couchbase.kafka.state.ZookeeperStateSerializer
 
A B C D E F G I J K L M N O P R S T U V Z 
Skip navigation links

Copyright © 2015 Couchbase, Inc.