public class ZookeeperStateSerializer extends Object implements StateSerializer
Constructor and Description |
---|
ZookeeperStateSerializer(CouchbaseKafkaEnvironment environment) |
Modifier and Type | Method and Description |
---|---|
void |
dump(ConnectorState connectorState) |
void |
dump(ConnectorState connectorState,
short partition) |
ConnectorState |
load(ConnectorState connectorState) |
StreamState |
load(ConnectorState connectorState,
short partition) |
public ZookeeperStateSerializer(CouchbaseKafkaEnvironment environment)
public void dump(ConnectorState connectorState)
dump
in interface StateSerializer
public void dump(ConnectorState connectorState, short partition)
dump
in interface StateSerializer
public ConnectorState load(ConnectorState connectorState)
load
in interface StateSerializer
public StreamState load(ConnectorState connectorState, short partition)
load
in interface StateSerializer
Copyright © 2015 Couchbase, Inc.