Projeto apresentado nesse vídeo para explicar como utilizar uma solução de CDC de forma prática com o Kafka Connect.
- Spring Boot
- Spring MVC
- Spring Data JPA
- MySQL
- Postgres
- Docker Compose
- Kafka
- Kafka Connect
- Debezium MySQL Source Connector
- JDBC Sink Connector
- Iniciar a infra com o docke-compose:
docker-compose up -d
- Adicionar os conectores do mysql e postgres:
curl -X POST -H "Content-Type:application/json" http://localhost:8083/connectors -d @mysql.json
curl -X POST -H "Content-Type:application/json" http://localhost:8083/connectors -d @postgres.json
- Conferir se os conectores foram adicionados com sucesso:
http GET :8083/connectors
- Iniciar os projetos Java
Os seguintes endpoints estarão disponíveis para cada microsserviço desse projeto:
- POST /posts
http POST :8080/posts content='Vídeo novo no canal'
- GET /posts
http :8080/posts
- POST /comments
http POST :8081/comments text='Excelente vídeo!' postId=1
- GET /comments
http :8081/comments