LoreonLabsPlatform
DocsHome
  • Overview

Intelligence

  • Markets
  • Builders
  • Research
  • Ecosystems
  • Launchpads
  • Search
Ecosystems

Go

kafka-mcp-server

A Model Context Protocol (MCP) server for Apache Kafka implemented in Go, leveraging franz-go and mcp-go.

GoEmerging
GitHubWebsite
Stars
—
Forks
—
Contributors
5
Last push
3mo ago

Recent commits

Latest commits.

  • feat: optimize ConsumeMessagesByTime with retry loop and larger fetch
    8b9ba6dheroims3mo ago
  • docs: add consume_messages_by_time tool documentation
    3fe0c55heroims4mo ago
  • chore: remove cmd/test/ debug utility
    e849b79heroims4mo ago
  • fix: correct partition type assertion from int to int32 in prompts.go
    e6bf795heroims4mo ago
  • refactor: simplify ConsumeMessagesByTime using kadm library
    f9aef38heroims4mo ago
fix: implement reset parameter correctly using separate client
4ec952dheroims4mo ago
  • feat: add reset parameter to consume_messages_by_time for offset management
    fb185dbheroims4mo ago
  • test: add ConsumeMessagesByTime integration test
    c33448fheroims4mo ago

    • Top contributors

    Builders behind this project.

    tuannvm
    46 commits
    dependabot[bot]
    19 commits
    heroims
    11 commits
    semantic-release-bot
    3 commits
    Function-0
    1 commits