public class KafkaWriter extends Object implements com.couchbase.client.deps.com.lmax.disruptor.EventHandler<DCPEvent>
KafkaWriter
is in charge of filtering and routing events to the Kafka cluster.Constructor and Description |
---|
KafkaWriter(CouchbaseKafkaEnvironment environment,
kafka.javaapi.producer.Producer<String,DCPEvent> producer,
Filter filter)
Creates a new
KafkaWriter . |
KafkaWriter(String kafkaTopic,
CouchbaseKafkaEnvironment environment,
kafka.javaapi.producer.Producer<String,DCPEvent> producer,
Filter filter)
Creates a new
KafkaWriter . |
Modifier and Type | Method and Description |
---|---|
void |
onEvent(DCPEvent event,
long sequence,
boolean endOfBatch)
Handles
DCPEvent s that come into the response RingBuffer. |
public KafkaWriter(CouchbaseKafkaEnvironment environment, kafka.javaapi.producer.Producer<String,DCPEvent> producer, Filter filter)
KafkaWriter
.environment
- the environment object, which carries settings.producer
- the kafka producer object.filter
- the filter to select events to publish.public KafkaWriter(String kafkaTopic, CouchbaseKafkaEnvironment environment, kafka.javaapi.producer.Producer<String,DCPEvent> producer, Filter filter)
KafkaWriter
.kafkaTopic
- name of Kafka topic to override CouchbaseKafkaEnvironment.kafkaTopic()
.environment
- the environment object, which carries settings.producer
- the kafka producer object.filter
- the filter to select events to publish.Copyright © 2015 Couchbase, Inc.