API Reference Klife v1.0.0

Behaviour for defining a custom partitioner.

Defines a kafka client.

Defines a consumer group.

Defines a topic configuration for a Klife.Consumer.ConsumerGroup.

Defines a fetcher.

Defines a producer.

Default partitioner implementation compatible with Kafka's DefaultPartitioner.

Kafka record representation.

Testing helper functions.

Defines a topic configuration.

Pool of transactional producers.