mcp

This project uses Quarkus, the Supersonic Subatomic Java Framework.

If you want to learn more about Quarkus, please visit its website: https://quarkus.io/.

Test on local K8s

# Start minikube
minikube start

# Setup Kafka and Apicurio
cd ~
git --depth=1 --branch main --single-branch https://github.com/streamshub/flink-sql-examples.git
chmod +x ~/flink-sql-examples/tutorials/scripts/data-gen-setup.sh
bash ~/flink-sql-examples/tutorials/scripts/data-gen-setup.sh

minikube tunnel

# Deploy to k8s
eval $(minikube -p minikube docker-env)
./mvnw clean install -Dquarkus.kubernetes.deploy=true

# Note: Remember to connect via proxy
export MCP_SERVER=`kubectl get svc mcp -o jsonpath='{.spec.clusterIP}'` && \
  envsubst < mcp_config_template.json > mcp_config.json && \
  npx @modelcontextprotocol/inspector --config ./mcp_config.json

License

Apache-2.0, see LICENSE.

Based on https://github.com/dmarrazzo/kafka-orders-ai/ (Apache-2.0).