Package cz.o2.proxima.core.storage.commitlog
-
Interface Summary Interface Description Partitioner An interface that each class configured inKafkaCommitLog.PARTITIONER_CLASS
must implement. -
Class Summary Class Description FirstPartitionPartitioner Partitioner that always send the ingest into first partition.KeyAttributePartitioner Partitioner based on key-value pairs.KeyPartitioner A partitioner based on key of entity.Partitioners Helper methods forpartitioners
. -
Enum Summary Enum Description Position An enum specifying the position in the commit log to start reading from.