YugabyteDB
Ask AI Ask AI about""
    OR Ask AIAsk AI
    • Star us on Github YugabyteDB Github
    • Join us on Slack YugabyteDB Community Slack
    • Start Now
      • YugabyteDB Aeon
        YugabyteDB AeonTry our fully-managed cloud DBaaS for free.No credit card requiredSign up
      • YugabyteDB
        YugabyteDBTry our open source distributed SQL database on your laptop.Download
    • Products
      • YugabyteDB
        YugabyteDBThe open source distributed SQL database
      • YugabyteDB Anywhere
        YugabyteDB AnywhereSelf-managed cloud DBaaS
      • YugabyteDB Aeon
        YugabyteDB AeonFully-managed cloud DBaaS
      • YugabyteDB Voyager
        YugabyteDB VoyagerDatabase migration service
    • Develop
    • Integrations
    • API
      • SQL APIs
      • YSQL
        YSQL
      • YCQL
        YCQL
      • Clients
      • ysqlsh
        ysqlsh
      • ycqlsh
        ycqlsh
      • Management APIs
      • YugabyteDB Anywhere API
        YugabyteDB Anywhere API
      • YugabyteDB Aeon API
        YugabyteDB Aeon API
    • FAQ
    • Releases
      • YugabyteDB
        YugabyteDB
      • YugabyteDB Anywhere
        YugabyteDB Anywhere
      • YugabyteDB Aeon
        YugabyteDB Aeon
      • YugabyteDB Voyager
        YugabyteDB Voyager
      • YugabyteDB Clients
        YugabyteDB Clients
      • Tech Advisories
        Tech Advisories
    Docs Menu
    • Develop
    • Tutorials
      • Hello world
        • Before you begin
        • Java
        • Go
        • Python
        • Node.js
        • Elixir
        • C
        • C++
        • C#
        • Ruby
        • Rust
        • PHP
      • Build and Learn
        • Overview
        • Debuting with PostgreSQL
        • Scaling with YugabyteDB
        • Tolerating outages
        • Going geo-distributed
        • Offloading operations
      • AI
        • RAG
          • Hello RAG
          • Similarity search - Azure
          • Similarity search - Google Vertex
        • Vector basics
          • Similarity search - LocalAI
          • Similarity search - Ollama
        • Agentic
          • Knowledge base - LlamaIndex
          • Query without SQL - LangChain
      • Cloud
        • Azure
          • Azure App Service
          • Azure Functions
          • Azure Key Vault
          • Azure Private Link
          • Azure API Management
          • Azure Event Hubs
        • Google Cloud
      • CDC
        • Kafka environments
          • Amazon MSK
          • Azure Event Hubs
          • Confluent Cloud
          • Redpanda
    • Learn app development
      • Transactions
        • Transaction retries
        • Performance tuning
        • Global applications
        • Error codes
      • Text search
        • Pattern matching
        • Similarity search
        • Full-text search
        • Phonetic search
      • Aggregations
      • Batch operations
      • Date and time
      • Strings and text
      • TTL for data expiration
    • Drivers and ORMs
      • Smart drivers
      • Java
        • JDBC Drivers
        • Connect an app
        • Use an ORM
      • Go
        • Go Drivers
        • Connect an app
        • Use an ORM
      • Python
        • Python drivers
        • Connect an app
        • Use an ORM
      • Node.js
        • Node.js Drivers
        • Connect an app
        • Use an ORM
      • Elixir
        • Phoenix
      • C
        • Connect an app
      • C++
        • Connect an app
      • C#
        • C# Drivers
        • Connect an app
        • Use an ORM
      • Ruby
        • Connect an app
        • Use an ORM
      • PHP
        • Connect an app
        • Use an ORM
      • Rust
        • Rust Drivers
        • Connect an app
        • Use an ORM
      • Build apps using ORMs
        • Java
        • Go
        • Python
        • Node.js
        • C#
        • Rust
        • PHP
      • Scala
        • Connect an app
      • Additional drivers
    • Data modeling
      • Primary keys
      • Secondary indexes
      • Hot shards
      • Partitioning tables
      • Common patterns
        • Time series
          • Global ordering by time
          • Ordering by time per entity
          • Automatic data expiration
          • Partition data by time
        • Key-value
        • Job queue
    • Build global applications
      • Global database
      • Duplicate indexes
      • Active-active multi-master
      • Active-active single-master
      • Latency-optimized geo-partitioning
      • Locality-optimized geo-partitioning
      • Follower reads
      • Read replicas
      • Real world scenarios
        • Global and geo-local tables
    • Build Multi-cloud Applications
      • Multi-cloud setup
      • Multi-cloud migration
      • Hybrid cloud
    • Best practices
      • YSQL data modeling
      • YSQL clients
      • YCQL applications
    • Quality of service
      • Rate limiting connections
      • Write-heavy workloads
      • Transaction priorities
    • Cloud-native development
      • Codespaces
      • Gitpod
    • Download
    • Join our community
      • Slack
      • Yugabyte University
      • GitHub
      • Yugabyte Friday Tech Talks
      • Forum
    • Contact Support
    1. YugabyteDB
    2. Develop
    3. Tutorials
    4. Kafka environments
    Change data capture environment tutorials

    Kafka environments EARLY ACCESS

    Use YugabyteDB CDC to stream data with different Kafka environments
    • Contribute List Contribute
      Report a doc issue Suggest new content Edit this page Contributor guide
    Amazon MSK
    Configure and stream data into Amazon MSK using Debezium connector.
    Azure Event Hubs
    Connect to Azure Event Hubs and ingest data into Azure Synapse Analytics for analysis.
    Confluent Cloud
    Use YugabyteDB connector to publish changes to Confluent Cloud.
    Redpanda
    Use YugabyteDB CDC with Redpanda as message broker.
    Azure Event Hubs
    Use Azure Event Hubs to stream real-time data for downstream processing.

    Learn more

    For more information on YugabyteDB CDC, see Change Data Capture.

    YugabyteDB
    © 2025 YugabyteDB, Inc. All Rights ReservedPrivacy Policy | Terms of Service