feat: add Apache Pulsar EventBus implementation (#2019)

This commit is contained in:
Teng Fu
2025-09-17 16:30:55 +08:00
committed by GitHub
parent 091e7a69c4
commit 315a93f8c0
10 changed files with 1534 additions and 89 deletions

View File

@ -74,12 +74,17 @@ export ES_PASSWORD=""
export ES_NUMBER_OF_SHARDS = "1"
export ES_NUMBER_OF_REPLICAS = "1"
export COZE_MQ_TYPE="nsq" # nsq / kafka / rmq
# Backend Event Bus
export COZE_MQ_TYPE="nsq" # nsq / kafka / rmq / pulsar
export MQ_NAME_SERVER="nsqd:4150"
# RocketMQ
export RMQ_ACCESS_KEY=""
export RMQ_SECRET_KEY=""
# Pulsar
# Use Pulsar as backend eventbus, MQ_NAME_SERVER example is: "pulsar:6650"
# Fill PULSAR_JWT_TOKEN for JWT auth, leave empty for no auth
export PULSAR_SERVICE_URL="pulsar://pulsar-service:6650"
export PULSAR_JWT_TOKEN=""
# Settings for VectorStore
# VectorStore type: milvus / vikingdb / oceanbase