Module●Since v0.3

kafka

Kafka-based chat message history by using confluent-kafka-python. confluent-kafka-python is under Apache 2.0 license. https://github.com/confluentinc/confluent-kafka-python

Attributes

attribute

logger

attribute

BOOTSTRAP_SERVERS_CONFIG: str

attribute

DEFAULT_TTL_MS: int

attribute

DEFAULT_REPLICATION_FACTOR: int

attribute

DEFAULT_PARTITION: int

Functions

function

ensure_topic_exists

Create topic if it doesn't exist, and return the number of partitions. If the topic already exists, we don't change the topic configuration.

Classes

class

ConsumeStartPosition

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.

class

KafkaChatMessageHistory

Chat message history stored in Kafka.

View source on GitHub

kafka

Attributes

Functions

Classes

LangChain Assistant

Menu

kafka

Attributes

Functions

Classes