ractogateway.kafka.consumer

Kafka consumer wrapper that returns normalized typed records.

class ractogateway.kafka.consumer.KafkaConsumerClient(*, config, consumer=None, key_deserializer=None, value_deserializer=None)[source]

Bases: object

Typed facade over kafka.KafkaConsumer.

Parameters:

  • config (KafkaConsumerConfig) – Consumer connection and polling options.

  • consumer (Any | None) – Pre-built consumer object; useful for tests and dependency injection.

  • key_deserializer (Callable[[Any], Any] | None) – Optional override for key decoding.

  • value_deserializer (Callable[[Any], Any] | None) – Optional override for value decoding.

poll(*, timeout_ms=None, max_records=None)[source]

Poll records and return normalized KafkaMessage entries.

Return type:

list[KafkaMessage]

commit()[source]

Commit currently consumed offsets.

Return type:

None

close()[source]

Close underlying consumer and release resources.

Return type:

None