For Agents
Run continuous SQL queries over streaming data from Kinesis Data Streams or Firehose without managing the underlying compute.
Get started with Amazon Kinesis Analytics in minutes using your preferred integration method.
# Add to your MCP client config (Claude Desktop, Cursor, Windsurf)
{
"jentic": {
"url": "https://api.jentic.com/mcp",
"auth": "oauth"
}
}
# Then ask your agent:
"create a streaming sql application over a kinesis stream"
# → Jentic returns the GET /events tool with parameter schema, agent executes.What an agent can do with Amazon Kinesis Analytics API.
Create SQL streaming applications via CreateApplication
Configure inputs from Kinesis Data Streams or Firehose with AddApplicationInput
Add reference data from S3 with AddApplicationReferenceDataSource
Stream output to Lambda or Firehose via AddApplicationOutput
GET STARTED
Use for: I need to set up a streaming SQL job over a Kinesis stream, Get the current state of a Kinesis Analytics application, List all streaming SQL applications in a region, Discover the schema of an input stream
Not supported: Does not handle Apache Flink applications, raw stream produce or consume traffic, or batch ETL — use for v1 SQL-based streaming application management only.
Jentic publishes the only available OpenAPI document for Amazon Kinesis Analytics, keeping it validated and agent-ready.
Jentic publishes the only available OpenAPI specification for Amazon Kinesis Analytics, keeping it validated and agent-ready. Kinesis Analytics is the v1 SQL-based service for running continuous queries over streaming data from Kinesis Data Streams or Kinesis Firehose. Its 20-endpoint API covers application creation, input and output configuration, reference data sources, CloudWatch logging options, schema discovery, and lifecycle controls to start and stop applications. The service is suited to teams running SQL transformations on event streams without standing up Spark or Flink clusters themselves.
Discover input schemas automatically with DiscoverInputSchema
Start and stop applications to control billing and throughput
Configure CloudWatch logging for SQL diagnostics
Patterns agents use Amazon Kinesis Analytics API for, with concrete tasks.
★ Real-Time Fraud Signals
Run continuous SQL queries over a transaction event stream to flag anomalous patterns in seconds. The Kinesis Analytics application reads from a Kinesis Data Stream, joins reference data from S3, and emits alerts to a downstream Firehose or Lambda output. Teams use this to detect velocity violations, dollar-amount thresholds, and other rule-based anomalies without writing Flink jobs.
Create application 'fraud-rules' with SQL that flags transactions where amount > 10000 from input stream txn-events
Stream Aggregation for Dashboards
Aggregate a high-volume event stream into per-minute metrics for live dashboards. Kinesis Analytics supports tumbling and sliding windows in SQL, which makes it straightforward to compute count, sum, and average over time windows and write the results into a destination stream that powers a near-real-time dashboard or alerting system.
Create an application that emits per-minute counts of input stream click-events to output stream click-counts using a tumbling window
Schema Discovery for Pipelines
Bootstrap a new streaming pipeline by discovering the schema of an input stream automatically. The DiscoverInputSchema operation samples records from a Kinesis stream and infers column names, types, and record format, which speeds up onboarding new event sources and reduces manual SQL configuration mistakes.
Run DiscoverInputSchema against stream txn-events with role arn:aws:iam::123:role/kinesis-analytics-discovery and return the inferred columns
AI Agent Streaming Pipeline Operations
AI agents call Kinesis Analytics through Jentic to create new applications when teams onboard event sources, start and stop applications based on cost guards, and inspect schemas before configuring downstream consumers. Through Jentic, the agent searches by intent, loads the operation schema, and executes with credentials stored in the vault. SigV4 signing happens inside Jentic so the agent runtime stays slim.
Search Jentic for 'start kinesis analytics application', load the StartApplication schema, and execute against application 'fraud-rules'
20 endpoints — jentic publishes the only available openapi specification for amazon kinesis analytics, keeping it validated and agent-ready.
METHOD
PATH
DESCRIPTION
/#X-Amz-Target=KinesisAnalytics_20150814.CreateApplication
Create a streaming SQL application
/#X-Amz-Target=KinesisAnalytics_20150814.StartApplication
Start an application
/#X-Amz-Target=KinesisAnalytics_20150814.StopApplication
Stop a running application
/#X-Amz-Target=KinesisAnalytics_20150814.AddApplicationInput
Configure an input stream
/#X-Amz-Target=KinesisAnalytics_20150814.AddApplicationOutput
Configure an output destination
/#X-Amz-Target=KinesisAnalytics_20150814.DiscoverInputSchema
Auto-discover the schema of a stream
/#X-Amz-Target=KinesisAnalytics_20150814.CreateApplication
Create a streaming SQL application
/#X-Amz-Target=KinesisAnalytics_20150814.StartApplication
Start an application
/#X-Amz-Target=KinesisAnalytics_20150814.StopApplication
Stop a running application
/#X-Amz-Target=KinesisAnalytics_20150814.AddApplicationInput
Configure an input stream
/#X-Amz-Target=KinesisAnalytics_20150814.AddApplicationOutput
Configure an output destination
Three things that make agents converge on Jentic-routed access.
Credential isolation
AWS access keys for Kinesis Analytics are stored encrypted in the Jentic vault. Jentic performs SigV4 signing at execution time, so raw AWS secrets never enter the agent's context.
Intent-based discovery
Agents search Jentic by intent such as 'create streaming sql application' or 'start kinesis analytics application' and Jentic returns the matching operation with its input schema, so the agent calls the right endpoint without parsing AWS docs.
Time to first call
Direct integration: 1-2 days to set up SigV4, IAM, and application lifecycle handling. Through Jentic: under 1 hour — search, load the schema, execute.
Alternatives and complements available in the Jentic catalogue.
Managed Streaming for Kafka
Managed Apache Kafka clusters
Choose MSK when downstream consumers expect Kafka protocol rather than streaming SQL transforms
AWS Lambda
Serverless function execution
Use Lambda outputs from a Kinesis Analytics application to fan results into custom code
Amazon EventBridge
Serverless event bus
Combine with Kinesis Analytics when downstream routing needs cross-account fan-out
Amazon CloudWatch Logs
Centralised log storage and search
Send Kinesis Analytics CloudWatch logging output to CloudWatch Logs for diagnostics
Specific to using Amazon Kinesis Analytics API through Jentic.
Why is there no official OpenAPI spec for Amazon Kinesis Analytics?
AWS does not publish an OpenAPI specification. Jentic generates and maintains this spec so that AI agents and developers can call Amazon Kinesis Analytics via structured tooling. It is validated against the live API and kept up to date. Get started at https://app.jentic.com/sign-up.
What authentication does the Kinesis Analytics API use?
Kinesis Analytics uses AWS Signature Version 4 (SigV4) HMAC request signing. Each call must be signed with an access key, secret key, and optional session token scoped to the kinesisanalytics IAM service. Through Jentic, these credentials sit in the encrypted vault and signing happens at execution time.
Can I run streaming SQL with the Kinesis Analytics API?
Yes. CreateApplication accepts an ApplicationCode field containing your SQL, plus input and output configurations that wire the application to Kinesis Data Streams, Firehose, or Lambda. The service handles parsing, scheduling, and scaling automatically.
How do I start a streaming application through Jentic?
Search Jentic for 'start kinesis analytics application', load the StartApplication schema, submit the application name and an InputConfiguration with the InputId and starting position, and Jentic will sign and execute the call.
What are the rate limits for the Kinesis Analytics API?
Per-region quotas apply, including a default cap on applications per account and TPS limits on control plane operations such as CreateApplication and DescribeApplication. Check the Kinesis Analytics service quotas in the AWS console for current values.
Can the Kinesis Analytics API discover an input schema automatically?
Yes. DiscoverInputSchema samples records from a Kinesis Data Stream or Firehose using a supplied IAM role and returns the inferred record format and column list. Use this before configuring AddApplicationInput so the schema is correct on the first attempt.
How does Kinesis Analytics differ from Kinesis Data Analytics for Apache Flink?
This API covers the v1 SQL-based service. AWS also offers a separate Kinesis Data Analytics for Apache Flink service for Java, Scala, and Python applications. Pick the SQL service for simple windowed transforms; pick Flink for stateful processing and custom code.
/#X-Amz-Target=KinesisAnalytics_20150814.DiscoverInputSchema
Auto-discover the schema of a stream