Managing Amazon Msk
by aws188af2f810ceNo license2.8K starsListed Oct 8, 2026Updated Oct 8, 2026Repository updated today
Operates Amazon MSK Provisioned clusters (Standard and Express brokers). Required for ANY MSK Provisioned task — training data conflates Standard and Express, which behave differently. Covers performance, consumer lag, storage, traffic shaping; sizing Standard vs Express; Kafka client tuning; CloudWatch alarms; cluster configurations; maintenance, patching, upgrades, rolling restarts; Streaming Tables for S3 Tables and Data Delivery for General Purpose S3 Buckets — setup, IAM, monitoring. Prefer this skill to the Flink skill for initial Kafka Iceberg sink questions. Triggers: MSK Provisioned (Express/Standard), Kafka, `kafka.*` or `express.*` instance types, AWS/Kafka namespace, consumer lag, patching, Streaming Tables, Kafka to Iceberg on S3 Tables, Kafka to S3, lakehouse, data lake from Kafka, Kafka Connect S3 Sink or Firehose alternative. DO NOT USE for MSK Connect or Replicator — search documentation instead. Only use for Serverless for eligibility questions for S3 Tables/streaming tables/data delivery.
Only the file list is public. File contents are available once the skill is installed in a workspace.
| Path | Size | Type |
|---|---|---|
| references/configure-clients.md | 13.3 KB | text/markdown |
| references/configure-cluster.md | 11.3 KB | text/markdown |
| references/data-delivery-for-general-purpose-s3.md | 15.7 KB | text/markdown |
| references/maintenance-operations.md | 13 KB | text/markdown |
| references/manage-storage.md | 8.5 KB | text/markdown |
| references/monitor-and-alarm.md | 15.4 KB | text/markdown |
| references/size-and-choose-cluster.md | 16.3 KB | text/markdown |
| references/streaming-tables.md | 19.5 KB | text/markdown |
| references/streaming-tables-troubleshooting.md | 5.3 KB | text/markdown |
| references/troubleshoot-consumer-lag.md | 11.5 KB | text/markdown |
| references/troubleshoot-performance.md | 9.3 KB | text/markdown |
| references/zk-to-kraft-migration.md | 728 B | text/markdown |
| scripts/msk_sizing.py | 39 KB | text/plain |
| SKILL.md | 10.1 KB | text/markdown |
Source and attribution
Source:aws/agent-toolkit-for-awsinskills/specialized-skills/analytics-skills/managing-amazon-mskat commit188af2f
License: No license
Content belongs to its original authors. SourceWeft indexes it from a public repository.
More from aws/agent-toolkit-for-aws
Rds Oss
aws
Advises on Amazon RDS MySQL, MariaDB and PostgreSQL instance creation, upgrades, commitment pricing, RDS Proxy and Blue/Green deployments.
Exporting Rds To S3
aws
Guides exporting Amazon RDS or Aurora snapshots to Amazon S3 as Parquet, covering IAM, KMS, monitoring and verification.
Creating Amazon Aurora Db Cluster With Instances
aws
Guides creation of an Amazon Aurora cluster with instances, including Secrets Manager password handling.
Debugging Lambda Timeouts
aws
Diagnoses AWS Lambda timeout failures by analyzing configuration, CloudWatch logs and metrics, networking, cold starts, and dependencies.
Waf
aws
Routes AWS WAF configuration tasks to per-task reference procedures for filtering web traffic.
Creating Api Gateway Stage
aws
Creates and configures AWS API Gateway stages with logging, tracing, throttling, WAF and IAM roles.
More in DevOps & Cloud
Playwright Devops
microsoft
DevOps workflows for Playwright: analyze GitHub Actions failures for the last commit on main and fetch failed job logs.
M5 Onboard
anthropics
Provisions M5Stack ESP32 boards by detecting them on USB, flashing UIFlow 2.0 firmware, and installing a MicroPython app bundle.
Yeet
openai
Stages, commits, pushes, and opens or updates a GitHub pull request in one flow using the GitHub CLI.
Runbook
anthropics
Creates or updates step-by-step operational runbooks for recurring tasks, including troubleshooting, rollback and escalation.
Incident Response
anthropics
Guides an incident response workflow: severity triage, status updates, mitigation tracking, and blameless postmortems.
Deploy Checklist
anthropics
Generates a pre-deployment readiness checklist covering pre-deploy, deploy, post-deploy and rollback triggers.