Skip to content

Synchronize data from PostgreSQL to Elasticsearch using Debezium

Notifications You must be signed in to change notification settings

wangyi12358/debezium-pg2es

Repository files navigation

Debezium pg2es

Debezium pg2es is a tool to replicate data from PostgreSQL to Elasticsearch using Debezium and Kafka.

Run containers

docker-compose up -d

Usage

Send message to Kafka

docker exec -it kafka /bin/bash
kafka-console-producer --topic test-topic --bootstrap-server localhost:9092

ES setup password

docker exec -it elasticsearch /bin/bash
bin/elasticsearch-setup-passwords interactive

Create connector

curl -X POST \
  -H "Content-Type: application/json" \
  --data @connect-config.json \
  http://localhost:8083/connectors

About

Synchronize data from PostgreSQL to Elasticsearch using Debezium

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published