Initialize a Receiver.

Initialize a Writer.

Returns a Context which will be asynchronously cancelled by a channel emitting zk.Event.

Receiver wraps around a kafka.Reader, offering methods for a secondary node to receive and replicate journal entries.

Writer abstracts Kafka operations.