Following is the siddhi cdc app I am running
@App:name('post')
@source(type = 'cdc' ,url = 'jdbc:postgresql://postgres:5432/shipment_db',
username = 'postgresuser', password = 'postgrespw',
table.name = 'shipment_db.public.shipments', operation = 'insert',
plugin.name='pgoutput',
@map(type='keyvalue', @attributes(shipment_id = 'shipment_id', order_id = 'order_id',date_created='date_created',status='status')))
define stream inputStream (shipment_id int, order_id int,date_created string, status string);
@sink(type = 'log')
define stream OutputStream (shipment_id int, date_created string);
@info(name = 'query1')
from inputStream
select shipment_id, date_created
insert into OutputStream;
Following is the command I used to run siddhi cdc app
docker run -it --net postgres-docker_default --rm -p 8006:8006 -v /home/vinoja/siddhi-apps:/apps siddhiimgpostgres:tag1 -Dapps=/apps/post.siddhi
What I need to know is how to use a specific version of cdc extension when runing this app in a docker environement