Skip to content

Latest commit

 

History

History
34 lines (24 loc) · 611 Bytes

README.md

File metadata and controls

34 lines (24 loc) · 611 Bytes
Raw

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