mcp-kafka
mcp-kafka is a server enabling AI assistants to interact with Apache Kafka using Model Context Protocol. It facilitates operations like topic management and message handling in Kafka clusters.
What are the prerequisites for using mcp-kafka?
You need Go 1.24 or higher and a running Kafka cluster (default connection: localhost:9092).
How do I build mcp-kafka from source?
Clone the repository, navigate to the directory, and run 'make build'. Optionally, specify the platform with 'make build GOOS=darwin GOARCH=arm64'.
What authentication methods are supported?
Currently, SASL_PLAINTEXT and PLAINTEXT authentication are supported. SASL_SSL is not supported.
How can I configure the mcp-kafka tool?
You can configure it using parameters like topic, num_partitions, replication_factor, produce_message_key, produce_message_value, produce_message_headers, and consumer_timeout.
Can I contribute to mcp-kafka?
Yes, contributions are welcome! Please feel free to submit a Pull Request.