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