Package cz.o2.proxima.direct.io.kafka

Interface Summary

Interface	Description
ElementSerializer<K,V>	A parser that transforms KV from Kafka (byte[], byte[]) into StreamElement.
OffsetCommitter.Callback	Callback to be called for performing the commit.

Class Summary

Class	Description
KafkaAccessor	Kafka writer and commit log using KafkaProducer.
KafkaConsumerFactory<K,V>	Factory for KafkaConsumers attached to the given commit log.
KafkaLogReader	A CommitLogReader implementation for Kafka.
KafkaStorage	Storage using KafkaProducer.
KafkaStreamElement	Data read from a kafka partition.
KafkaStreamElement.KafkaStreamElementSerializer
KafkaWatermarkConfiguration
KafkaWriter<K,V>	${link OnlineAttributeWriter} implementation for Kafka.
OffsetCommitter<ID>	A committer of kafka offsets.