LICENSE
MANIFEST.in
README.md
pyproject.toml
requirements.txt
kafka_mcp/__init__.py
kafka_mcp/__main__.py
kafka_mcp/api_client.py
kafka_mcp/auth.py
kafka_mcp/kg_ingest.py
kafka_mcp/mcp_config.json
kafka_mcp/mcp_server.py
kafka_mcp/models.py
kafka_mcp.egg-info/PKG-INFO
kafka_mcp.egg-info/SOURCES.txt
kafka_mcp.egg-info/dependency_links.txt
kafka_mcp.egg-info/entry_points.txt
kafka_mcp.egg-info/requires.txt
kafka_mcp.egg-info/top_level.txt
kafka_mcp/api/__init__.py
kafka_mcp/api/api_client_base.py
kafka_mcp/api/api_client_connect.py
kafka_mcp/api/api_client_kafka.py
kafka_mcp/api/api_client_native.py
kafka_mcp/connectors/__init__.py
kafka_mcp/connectors/mcp_source_presets.json
kafka_mcp/connectors/tool_schema_fingerprints.json
kafka_mcp/mcp/__init__.py
kafka_mcp/mcp/mcp_kafka.py
kafka_mcp/mcp/mcp_kafka_cdc.py
kafka_mcp/mcp/mcp_kafka_connect.py
kafka_mcp/ontology/__init__.py
kafka_mcp/ontology/certification.json
kafka_mcp/ontology/kafka.ttl
kafka_mcp/ontology/fixtures/records.json
kafka_mcp/ontology/mappings/source.yaml
kafka_mcp/ontology/migrations/manifest.json
kafka_mcp/ontology/shapes/connector.shacl.ttl
kafka_mcp/prompts/__init__.py
kafka_mcp/prompts/streaming_specialist.json
kafka_mcp/skills/__init__.py
kafka_mcp/skills/kafka-connect-cdc-operations/SKILL.md
kafka_mcp/skills/kafka-connect-cdc-operations/WORKFLOW.md
kafka_mcp/skills/kafka-connect-cdc-operations/agents/arbora.yaml
kafka_mcp/skills/kafka-connect-cdc-operations/agents/openai.yaml
kafka_mcp/skills/kafka-consumer-group-lag/SKILL.md
kafka_mcp/skills/kafka-consumer-group-lag/WORKFLOW.md
kafka_mcp/skills/kafka-mcp-operations/SKILL.md
kafka_mcp/skills/kafka-mcp-operations/agents/openai.yaml
kafka_mcp/skills/kafka-mcp-operations/references/catalog.md
kafka_mcp/skills/kafka-streaming-io/SKILL.md
kafka_mcp/skills/kafka-streaming-io/WORKFLOW.md
kafka_mcp/skills/kafka-topic-administration/SKILL.md
kafka_mcp/skills/kafka-topic-administration/WORKFLOW.md
tests/test_api_client_base.py
tests/test_api_client_connect.py
tests/test_default_content_surfaces.py
tests/test_health_check.py
tests/test_init_dynamics.py
tests/test_kg_ingest.py
tests/test_mcp_kafka_cdc.py
tests/test_mcp_kafka_connect.py
tests/test_startup.py
tests/test_verify_api_integration.py