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#