@forgeframework/mcp-events

MCP server for Kafka event streaming.

Part of the Forge Framework — a TypeScript framework for backend microservices and web applications.

Installation

npm install @forgeframework/mcp-events

Usage

import { McpEventsServer } from '@forgeframework/mcp-events';

const server = new McpEventsServer({
  brokers: ['kafka-1:9092', 'kafka-2:9092', 'kafka-3:9092'],
  topics: {
    orders: {
      name: 'orders.created',
      schema: 'orders-value',
      allowProduce: true,
      allowConsume: true,
    },
    notifications: {
      name: 'notifications.send',
      allowProduce: true,
      allowConsume: false,
    },
    audit: {
      name: 'audit.events',
      allowProduce: false,
      allowConsume: true,
    },
  },
  consumerGroup: {
    groupId: 'mcp-events-agent',
    autoCommit: true,
    autoCommitInterval: 5000,
  },
  schemaRegistry: {
    url: 'http://schema-registry:8081',
  },
  defaults: {
    produceTimeout: 5000,
    consumeTimeout: 10000,
    maxConsumeMessages: 50,
  },
});

await server.start({ type: 'stdio' });

Documentation

Full API reference and guides: https://carbonforge.io/framework/docs/mcp/mcp-events

(Documentation site launching soon.)

License

MIT © Carbon Forge