abhirockzz/debezium-azure-postgres-cdc

Stars
3
Rank 3,963,521 (Top 79 %)
Language
Created over 4 years ago
Updated over 1 year ago

abhirockzz/debezium-azure-postgres-cdc

abhirockzz

There are no reviews yet. Be the first to send feedback to the community and the maintainers!

Getting started with setting up a change data capture based system on Azure using Debezium, Azure DB for PostgreSQL and Azure Event Hubs (for Kafka). It will use the Debezium PostgreSQL connector to stream database modifications from PostgreSQL to Kafka topics in Azure Event Hubs

kubexpose-operator

CRD and Operator to access your Kubernetes Deployment over the Internet

kubernetes-in-a-nutshell

Code (and YAML!) for the "Kubernetes in a Nutshell" blog series

redis-streams-in-action

Go, Rust, Java services to showcase Redis Streams and RediSearch in action

kafka-kubernetes-strimzi

Kafka on Kubernetes with Strimzi

jaxrs-with-jwt

A Java EE sample which demonstrates usage of JSON Web Tokens with JAX-RS for (stateless) authentication

kafka-streams-example

Kafka Streams based microservice

kafka-websocket

kafEEne: Kafka + Websocket

kubernetes-keda-prometheus

Kubernetes apps auto scaling with Prometheus and KEDA

etcd-watch-go-client

etcd Watch using Go client

practical-redis

Code for the book - Practical Redis

docker-kafka-streams

Kafka streams microservice on Docker

chat-redis-websocket-go

scalable-websocket-chat-with-hazelcast

Horizontal scalability for WebSocket applications

just-enough-go

kafka-streams-interactive-queries

Interactive Queries in Kafka Streams

kafka-go-docker-quickstart

Docker based example for Kafka using Go client

rust-redis-101

An example for how to use the Rust client for Redis

nats-on-kubernetes-example

NATS cluster on Kubernetes with Java producer and Go subscriber

cdk8s-for-go-developers

Use Go to define Kubernetes applications

tour-of-dapr

Resources for "A Tour of Dapr"

javaee-cdi-concurrency-utils

Example of using CDI beans as tasks managed by Java EE Concurrency Utilities

websocket-chat

Sample code for the 'Java WebSocket API Handbook'

dapr-nats-pubsub

NATS pubsub with Dapr on Kubernetes

mspindiasummit

MSP India Summit

accs-spring-cloud-stream-kafka

Spring Cloud Stream apps with Apache Kafka on Oracle Cloud

redis-timeseries-kafka

Process time series data with Redis and Kafka

keda-eventhubs-kafka

Scale Kafka apps on Kubernetes using KEDA (keda.sh)

accs-kafka-cassandra-tweet-analysis-sample

Tweet analysis app with Kafka and Cassandra

kubernetes-configmap-auto-update

Automatically update your Kubernetes app configuration using this technique

strimzi-kafka-connect-eventhubs

Kafka Connect on Kubernetes using Strimzi Operator

serverless-url-shortener-golang

ngrok-kubernetes

Expose Kubernetes services with ngrok

restful-ejb-timers

Create/Fetch/Cancel EJB timers on the fly via a RESTful interface

awsome-slack-backend

Using AWS Lambda Function URL to build a Serverless backend for Slack

redis-cdi-example

Example for a Java EE CDI producer for Jedis (Redis Java client)

abhirockzz-serverless-go-slack-app

Serverless app using Go and Azure Functions

fn-text2pdf-events

Object Storage events to trigger Text to PDF conversion using Oracle Functions

dapr-eventhubs-bindings

Azure Event Hubs integration with Dapr, a set of distributed system building blocks for microservices development

kafka-adx-postgres-cdc-demo

How to use Change Data Capture to stream database modifications from PostgreSQL to Azure Data Explorer via Apache Kafka

kafka-streams-apis

Examples for Kafka Streams APIs

kafka-streams-stateful-kubernetes

Use Kubernetes to deploy stateful Kafka Streams applications

Simplifying-JAX-RS-caching-with-CDI

Using CDI Producer to ease cache control in RESTful web services using JAX-RS

kafka-consumer-groups

Scaling out with Kafka Consumer Groups

kafka-dapr-eventhubs-k8s

Using Kafka binding for Dapr with Kubernetes and Azure Event Hubs

kafka-javaee-concurrency-utilities

kafEEne: Kafka + Java EE Concurrency Utilities

synapse-azure-data-explorer-101

Getting started with Azure Synapse and Azure Data Explorer

Jupyter Notebook

azure-kafka-iot

Real-time IoT analytics with Azure Cosmos DB, Azure Synapse Analytics and Confluent Cloud

Jupyter Notebook

azure-cognitive-translateapp

Use Azure Cognitive Services to build a translator app hosted on Azure App Service

rust-kafka-101

Getting started with Rust and Kafka

aks-azuredisk-static-pv

How to use Azure Disk as a storage medium for your apps deployed to Azure Kubernetes Service.

debezium-javaee-test-drive

Debezium Java EE test drive...

jcache-listerners-loaders-writers

Using JCache event listeners together with loaders & writers

fn-email-app

Function to send emails using Oracle Cloud Infrastructure Email Delivery

FlexiTimeouts

Implementing auto retry in Java EE applications

fn-oracledb-atp-sample

Oracle functions integrated with Oracle Autonomous Transaction Processing

cosmosdb-synapse-workshop

Near Real Time Analytics with Azure Synapse Link for Azure Cosmos DB

learning-rust

code repo for "Learning Rust" blogs

fn-kafka-connect-sink-connector

Kafka Connector (sink) to invoke Fn functions using OCI signature based authentication

payara-kafka-mdb

Dockerized example for Payara Micro Kafka connector - read from Kafka using a MDB

oracle-functions-oci-object-store

Oracle functions working with Object Storage (Oracle Cloud Infrastructure)

apache-curator-distributed-lock

Explore distributed locks using InterProcessMutex in Apache Curator

redis-todo-cli-app

redis-websocket-javaee

Displays the currently trending Meetup groups based on their (live) RSVPs feed

accs-golang-cassandra-tweet-query-service

Go based REST API for querying tweet data in Cassandra

kubexpose

Kubernetes Operator to expose a Deployment to the internet using ngrok

redis-celery-kubernetes-keda

Autoscale Redis applications on Kubernetes

javaee8-jaxrs-sse-client

JAX-RS 2.1 SSE Client API support in Java EE 8

oracle-functions-oci-streaming

Invoke Oracle Streaming Service from Oracle Functions

postgres-kafka-cassandra

Data Pipeline between PostgreSQL and Cassandra using Kafka Connect

accs-go-kafka-mysql

Example for Go based Kafka consumer pushing data to MySQL (all on Oracle Cloud)

Oracle-IDM-11g-R2-PS2-Automated-Deployment-Tool

The new Deployment Tool for Oracle IDM 11g R2 automates the installation and configuration of specific Oracle IDAM

cdi-async-events

Asynchronous events in CDI 2.0

kafka-cosmosdb-cassandra

Integrate Apache Kafka and Azure Cosmos DB Cassandra API using Kafka Connect

synapse-spark-sqldb

Jupyter Notebook

cosmos-java-cfp-app

cosmos change feed java sample app

lambda-functionurl-dynamodb-sam-go

Use Lambda Function URL to write a Serverless app backed by DynamoDB

ejb-annotations-primer

Code repo for the 'EJB Annotations Primer' (mini) book

go-redis-apprunner

Use AWS CDK to package and deploy the app (along with infrastructure), and run it as an AWS App Runner service that integrates with MemoryDB for Redis

accs-cassandra-twitter-timeseries-app

Simple time series app with Twitter data using Cassandra on Oracle Data Hub Cloud

jaxrs-sse-mbw

Handling custom objects with JAX-RS SSE API

accs-javaee8

Java EE 8 application on Oracle Application Container Cloud using Payara Micro 5

accs-javaee-emp-app

Employee management Java EE application on Oracle Application Container Cloud

fn-hello-tensorflow

Image classification as a serverless Function using TensorFlow

redisearch-tweet-analysis

Real time tweet ingestion, indexing and searching using RedisSearch

accs-kafka-streams

Kafka Streams based stateful stream processing application on Oracle Application Container Cloud

accs-golang-beego-quickstart

Quick start: deploy a Go web app on Oracle Application Container Cloud

fn-redis-example

Go and Java Fn functions talking to Redis

azure-dataexplorer-go

Tutorial on how to use the Azure Data explorer Go SDK to ingest data from a Azure Blob storage container and query it programmatically using the SDK

fn-oci-compute

Fn functions to list and update OCI Compute instances using OCI Go SDK

twitter-leaderboard-app

Built with Lambda, Redis, CDK and Go

fn-java-sdk-invoke

Invoke Oracle Functions using the OCI Java SDK

junit-sample-project

simple example for JPA unit testing

websocket-http-session

How to access HttpSession in WebSocket endpoint

mongodb-changestreams-processor

Demonstrates how to use Change Streams in MongoDB with the official Go driver

dynamodb-streams-lambda-golang

accs-psm-cli-docker

Deploy your apps to Oracle Application Container Cloud using PaaS Service Manager CLI on Docker

JAXRS2-0-Custom-Marshalling

To demonstrate custom marshalling with JAXRS 2.0 by leveraging MessageBodyWriter and MessageBodyReader

msk-cdk-apprunner-eks-dynamodb

End-to-end app with producer on App Runner sending data to MSK. Consumer on EKS persisting data to DynamoDB

mongodb-kafkaconnect-kubernetes

MongoDB Kafka Connect on Kubernetes using Strimzi

oci-user-management-util

Java utility to automate user creation and deletion in Oracle Cloud infrastructure