Skip to content

Files

Latest commit

 

History

History

db-to-streams-service

Folders and files

NameName
Last commit message
Last commit date

parent directory

..
src/main
src/main
 
 
Dockerfile
Dockerfile
 
 
README.md
README.md
 
 
pom.xml
pom.xml
 
 

README.md

Debezium to Streams

This service is used to capture changes in the RDBMS and put all events on a streams

Below the structures that are generated by Debezium for Insert, Update and Delete operations:

  • INSERT
Struct{
    after=Struct{actor_id=9000,first_name=John,last_name=Doe,dob=1973},
    source=Struct{version=1.1.0.Final,connector=mysql,name=redis-stream-service-dev,ts_ms=1586575902000,db=inventory,table=actors,server_id=223344,file=mysql-bin.000003,pos=359,row=0,thread=5},op=c,ts_ms=1586575902270}
  • UPDATE
Struct{
    before=Struct{actor_id=9000,first_name=John,last_name=Doe,dob=1973},
    after=Struct{actor_id=9000,first_name=Johnny,last_name=Doe,dob=1973},
    source=Struct{version=1.1.0.Final,connector=mysql,name=redis-stream-service-dev,ts_ms=1586576003000,db=inventory,table=actors,server_id=223344,file=mysql-bin.000003,pos=649,row=0,thread=5},op=u,ts_ms=1586576003261}

*DELETE

Struct{
    before=Struct{actor_id=9000,first_name=Johnny,last_name=Grall,dob=1973},
    source=Struct{version=1.1.0.Final,connector=mysql,name=redis-stream-service-dev,ts_ms=1586576052000,db=inventory,table=actors,server_id=223344,file=mysql-bin.000003,pos=963,row=0,thread=5},op=d,ts_ms=1586576052199}