Skip to main content
Glama

DARPEngine

by DARPAI
main.py681 B
import asyncio from kafka import KafkaAdminClient from kafka.admin import NewTopic from kafka.errors import TopicAlreadyExistsError from registry.src.logger import logger from registry.src.settings import settings from worker.src.consumer import Consumer if __name__ == "__main__": try: admin = KafkaAdminClient(bootstrap_servers=settings.broker_url) worker_topic = NewTopic( name=settings.worker_topic, num_partitions=1, replication_factor=1 ) admin.create_topics([worker_topic]) except TopicAlreadyExistsError: pass consumer = Consumer() logger.info("Starting consumer") asyncio.run(consumer.start())

MCP directory API

We provide all the information about MCP servers via our MCP API.

curl -X GET 'https://glama.ai/api/mcp/v1/servers/DARPAI/darp_engine'

If you have feedback or need assistance with the MCP directory API, please join our Discord server