消费起始位置#

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

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

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