davyam edited a comment on pull request #4065: URL: https://github.com/apache/nifi/pull/4065#issuecomment-671375800
> > > > With the replacement from JSON Simple to Jackson, the output (content) changed too. > > > > Example: > > > > ``` > > > > { > > > > "tupleData" : { > > > > "codigo" : 4, > > > > "nome" : "CDC", > > > > "data_fund" : "1929-10-19" > > > > }, > > > > "relationName" : "public.cidade", > > > > "type" : "insert" > > > > } > > > > ``` > > > > > > > > > @davyam could you please possibly explain how to use Jackson JSON format for a CDC event? Or maybe it is documented somewhere. > > > Thanks! > > > > > > > > With the replacement from JSON Simple to Jackson, the output (content) changed too. > > > > Example: > > > > ``` > > > > { > > > > "tupleData" : { > > > > "codigo" : 4, > > > > "nome" : "CDC", > > > > "data_fund" : "1929-10-19" > > > > }, > > > > "relationName" : "public.cidade", > > > > "type" : "insert" > > > > } > > > > ``` > > > > > > > > > @davyam could you please possibly explain how to use Jackson JSON format for a CDC event? Or maybe it is documented somewhere. > > > Thanks! > > > > > > @energy2522 if I understood your question, you are asking for more detail about the CDC event that is returned in flowfile content in JSON type. > > So, for each row in an event (INSERT, UPDATE, DELETE) we have a JSON in this format: > > ``` > > { > > "tupleData" : { _JSON object with all of the fields and their values_ }, > > "relationName" : _Table's name_, > > "type" : _Event type (INSERT, UPDATE, DELTE, BEGIN*, COMMIT*)_ > > } > > ``` > > > > > > *BEGIN and COMMIT events are included if the "Include Begin/Commit Events" property are checked. > > More info here: [https://github.com/davyam/pgEasyReplication](url) > > @davyam I tried to use this processor in my local task. For now the processor returns flowFiles with content in such JSON format {"insert":{"cidade":{"codigo":4,"nome":"New York","data_fund":"2020-02-24"}}} > > But, as you wrote after replacement from JSON Simple to Jackson it should be in another format. So, my question is should I somehow configure this processor to get output in Jackson format? > > Thanks! You are using the old version. To build the last version of this NiFi processor follow these steps: ``` ### Download repo git clone https://github.com/gerdansantos/nifi.git cd nifi ### Export MAVEN options export MAVEN_OPTS="-Xms1024m -Xmx3076m -XX:MaxPermSize=256m" ### Export JAVA_HOME # On MacOS export JAVA_HOME=$(/usr/libexec/java_home) # On Linux # export JAVA_HOME=/usr/jdk64/jdk1.8.0_112 ### Build bundle cd nifi-nar-bundles/nifi-cdc/nifi-cdc-postgresql-bundle # You can omit the -Pinclude-grpc if you're not on a platform that it supports. Include -DskipTests to compile tests, but skip running them. mvn -T C2.0 clean install -Pinclude-grpc -DskipTests ### Move NAR to NiFi libs dir cp nifi-cdc-postgresql-nar/target/nifi-cdc-postgresql-nar-1.12.0-SNAPSHOT.nar /Users/davyam/Documents/PROGRAMS/nifi-1.12.0-SNAPSHOT/lib/ ### Check processor in NiFi Canvas cd /Users/davyam/Documents/PROGRAMS/nifi-1.12.0-SNAPSHOT sh bin/nifi.sh run # Wait a few minutes to access http page http://localhost:8080/nifi/ # CNTRL+C to shuts down NiFi ``` ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org