ConsumeStartPosition#

class langchain_community.chat_message_histories.kafka.ConsumeStartPosition(value, names=None, *, module=None, qualname=None, type=None, start=1, boundary=None)[source]#

Consume start position for Kafka consumer to get chat history messages. LAST_CONSUMED: Continue from the last consumed offset. EARLIEST: Start consuming from the beginning. LATEST: Start consuming from the latest offset.

LAST_CONSUMED = 1#
EARLIEST = 2#
LATEST = 3#