aws avatar

Developing Applications On Managed Service For Apache Flink

This is the skill you need loaded before Claude answers anything about Apache Flink or Amazon Managed Service for Apache Flink. It enforces a critical rule: always read the reference files instead of relying on training data, because MSF has service-specific constraints that contradict generic Flink knowledge. Things like the KPU resource model, the confusing v1/v2 API naming split (kinesisanalyticsv2 for CLI, kinesisanalytics for IAM), prohibited checkpoint configs in application code, and Flink 1.x to 2.x migration gotchas. The skill includes 20+ reference files covering connectors, KPU sizing, checkpoint tuning, IAM policy mistakes, Iceberg streaming, and restart loop diagnosis. If you're building real-time data pipelines on MSF or debugging why your Flink app won't start, this removes the guesswork.

skills.sh installs
5.4K
GitHub stars
3.4K
last updated
Aug 21, 2026

Install

$ npx -y skills add aws/agent-toolkit-for-aws --skill developing-applications-on-managed-service-for-apache-flink --agent claude-code

Installs into .claude/skills of the current project.

Files

Managed Service for Apache Flink

Overview

Domain expertise for Apache Flink applications on Amazon Managed Service for Apache Flink (MSF). Covers development, KPU resource management, connectors, state management, monitoring, IaC deployment, and version migration.

Execute commands using available tools from the AWS MCP server when connected — it provides sandboxed execution, audit logging, and observability. When the MCP server is not available, fall back to the AWS CLI or shell as needed.

General Guidance

Before starting, ensure you have a clear understanding of the user persona, use case, and requirements:

STOP: Determine the users background and use case before proceeding:

  • Are they new to Flink? New to Managed Service for Apache Flink?
  • Are they familiar with Java development?
  • Is the use case complex with lots of business logic? Or simple and declarative?

These will inform how to organize the project, and whether to use Flink Table API or DataStream API. In general, assume the DataStream API.

Example Workflow for New Applications

Sponsors

Details

Repository
github.com/aws/agent-toolkit-for-aws
Categories
Testing & QA, AI & Agent Building, Cloud & Infrastructure, CLI & Terminal
First seen
Jul 14, 2026

More from aws/agent-toolkit-for-aws

All 56
1affaan-m avatarquarkus-verificationaffaan-m/eccVerification loop for Quarkus projects: build, static analysis, tests with coverage, security scans, native compilation, and diff review before release or PR.5.4Kskills.sh installs
2cursor avatarinterrogatecursor/pluginsUse for \"interrogate\", \"adversarial review\", \"multi-model review\", \"challenge this\", \"stress test this code\", \"find blind spots\", or \"tear this apa5.3Kskills.sh installs
3claude-office-skills avatarnews-monitorclaude-office-skills/skillsSet up news monitoring strategies, analyze news coverage, and synthesize current events. Create news digests and media analysis reports.5.3Kskills.sh installs
4dotnet avatarfilter-syntaxdotnet/skillsReference data for test filter syntax across all platform and framework combinations: VSTest --filter expressions, MTP filters for MSTest/NUnit/xUnit v3/TUnit, 5.2Kskills.sh installs
5dpearson2699 avatarios-accessibilitydpearson2699/swift-ios-skillsBuild and audit SwiftUI, UIKit, and AppKit accessibility for VoiceOver, Voice Control, Switch Control, Full Keyboard Access, Dynamic Type, focus restoration, la5.2Kskills.sh installs
6dotnet avatardotnet-webapidotnet/skillsGuides creation and modification of ASP.NET Core Web API endpoints with correct HTTP semantics, OpenAPI metadata, and error handling. USE FOR: adding new API en5.2Kskills.sh installs