我试图将我的 postgresql 数据库与 wso2 流集成器工具连接,知道我已经安装了 Change Data Capture - PostgreSQL 和 RDBMS - Postgre SQL 扩展,并且我对 db 坐标感到满意,所以请
@App:name("testApp")
@App:description("Description of the plan")
@source(type='cdc', url="jdbc:postgresql://localhost:5432/postgres",username="root", password="", table.name = "test",mode = "polling",polling.column ="att2",polling.interval = '2',jdbc.driver.name = "org.postgresql.Driver",
@map(type="keyvalue"))
define stream insertStream(att1 string, att2 string);
@sink(type='log')
define stream outputStream(att1 string, att2 string);
from insertStream
insert into outputStream;