public class MutationsFilter extends Object implements Filter
MutationsFilter
allows only mutations to be sent to Kafka.Constructor and Description |
---|
MutationsFilter() |
Modifier and Type | Method and Description |
---|---|
boolean |
pass(DCPEvent dcpEvent)
Returns true if event is mutation.
|
Copyright © 2015 Couchbase, Inc.