langchain_community.chat_message_histories.kafka.ensure_topic_exists

langchain社区.chat_message_histories.kafka.ensure_topic_exists(admin_client: AdminClient, topic_name: str, replication_factor: int, partition: int, ttl_ms: int) → int

如果主题不存在，则创建主题并返回分区数。如果主题已存在，则不更改主题配置。

参数

• admin_client (AdminClient) –

• topic_name (str) –

• replication_factor (int) –

• partition (int) –

• ttl_ms (int) –

返回类型

int