Monitors the status of all MSK cluster in an AWS account and sends out notifications when a cluster is not in the ACTIVE state.

Schema Registry with MSK IAM auth

Streamline Apache Kafka with Conduktor Platform. 🚀

This is a SerDe library to interact with the AWS Glue Schema Registry. It makes it easy to encode and decode messages with Avro schemas and the AWS' wire format.

Versions

Log data -> Kafka (MSK) - Lambda -> OpenSearch - Anomaly Detection

Thala is an Intelligent incident management system for automated detection, classification, and resolution tracking. this is an efficient tool that integrates with existing developer ecosystem

Code samples for various topic on & related to Managed Streaming for Apache Kafka (MSK)

Containerized Python API → Kafka cluster → AWS Lambda consumer, via Terraform

AWS SSM 連線到 EC2、打通 RDS & Elasticache & MSK 到本機、使用 SCP 傳送檔案/拉取遠端檔案到本機

Apache Kafka and Related Projects

AWS Secrets Manager Config Provider for Apache Kafka

Dynamic Terraform module, which creates a Kinesis Firehose Stream and others resources like Cloudwatch, IAM Roles and Security Groups that integrate with Kinesis Firehose. Supports all destinations and all Kinesis Firehose Features.

Resilience-first KafkaJS helpers for production-grade apps on KafkaJS.

Create a function that invokes a provided function according to a predicate function.

Create a function that invokes a provided function according to a predicate function.

Real-time streaming pipeline using AWS CDK with Amazon MSK Serverless, Amazon Managed Flink, Amazon Kinesis Data Firehose, Amazon S3, and Amazon SageMaker Feature Store for stock market data processing.

radio configuration running on the traffic stop boxes

C API for registering an N-API module exporting a strided array interface for applying a unary callback to an input strided array according to a mask strided array.

Terraform module for building AWS Managed Streaming for Kafka cluster