Hi Alim , thanks for this very wonderful post on using Nifi as CDC. Is there a provision in Nifi to use something similar for Oracle Database ? ... View more

Hi goto cd /kafka-logs under the kafka-logs goto vi meta.properties in that change broker.id=1001 to 1 then restart the kafka ... View more

I have uploaded a NiFi example template on https://github.com/maxbback/nifi-xml ... View more

How do I check if HS2 can reach port 2181? ... View more

Hi Alim,   I just started to repeat our work and found the following error.  My testing environment is : Ubuntu 16.04;  MySQL and NiFi are installed in the system, I could access to MySQL via the terminal in a remote Windows PC. Does anyone know how to address the issue? Thanks. Kind regards,   Raymond ... View more

@Deb This looks to be related to parquet way for coding being different in spark than in hive. Have you tried reading a different non parquet table? Try adding the following configuration for the parquet table: .config("spark.sql.parquet.writeLegacyFormat","true") If that does not work please open a new thread on this issue and we can follow up on this new thread. Thanks! ... View more

Thanks Felix for your quick response. It worked. Thanks a lot. ... View more

could you please share the nifi template for this. I am not able to achieve this. ... View more