消费起始位置#
- 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#