amazon-msk

There are 10 repositories under amazon-msk topic.

  • build-on-aws/building-apache-kafka-connectors

    Sample code that shows the important aspects of developing custom connectors for Kafka Connect. It provides the resources for building, deploying, and running the code on-premises using Docker, as well as running the code in the cloud.

    Language:Java5223014

  • aws-samples/aws-cdk-managed-elkk

    Managed ELKK stack implemented with the AWS CDK

    Language:Python428119

  • build-on-aws/prioritizing-event-processing-with-apache-kafka

    Technical solution to implement event processing prioritization with Apache Kafke using the concept of buckets.

    Language:Java23724

  • amazon-archives/cdc-neo4j-msk-neptune

    After you migrate from an existing graph database to Amazon Neptune, you might want to capture and process changed data in real time. Continuous replication of databases using the change data capture technique allows you to unlock your data and make it available to other systems for use cases such as distributed data processing, building an enterprise data lake, and modernizing your existing database. In the previous post of this series, we demonstrated with an example solution, how to perform automated migration from Neo4j to Amazon Neptune. If you are looking beyond one-time migration and want to keep both databases in sync you might want to run an ongoing replication using the change data capture technique.

    Language:JavaScript5802

  • garystafford/kstreams-on-msk

    Kafka KStreams example using Amazon MSK with IAM Auth

    Language:Java3301

  • aws-samples/aws-msk-cdc-data-pipeline-with-debezium

    Data Pipeline for CDC data from MySQL DB to Amazon S3 through Amazon MSK using Amazon MSK Connect (Debezium).

    Language:Python2202

  • garystafford/msk-perf-test

    Amazon MSK Performance Testing

    230

  • averemee-si/aws-secrets-manager-kafka

    AWS Secrets Manager Config Provider for Apache Kafka

    Language:Java0200

  • create-speech-to-text-pipeline/pipeline

    A tool that can be deployed to process posting and receiving text and audio files from and into a data lake, apply transformation in a distributed manner, and load it into a warehouse in a suitable format to train a speech-to-text model

    Language:Jupyter Notebook01128

  • sve2-2021ss/mom-ammer

    Demo event analytics platform based on Apache Kafka (Confluent).

    Language:Python0300