langchain_community.chat_message_histories.kafka.ConsumeStartPosition

class langchain_community.chat_message_histories.kafka.ConsumeStartPosition(value)[source]

Kafka消费者获取聊天历史消息的开始位置。LAST_CONSUMED:从上次消费的偏移量继续。EARLIEST:从头开始消费。LATEST:从最新的偏移量开始。

LAST_CONSUMED = 1
EARLIEST = 2
LATEST = 3