Since the previous link (hortonworks.com) has expired, please refer to the updated links below: Change Data Capture (CDC) with Apache NiFi – Part 1 of 3 https://community.cloudera.com/t5/Community-Articles/Change-Data-Capture-CDC-with-Apache-NiFi-Part-1-of-3/ta-p/246623 Change Data Capture (CDC) with Apache NiFi – Part 2 of 3 https://community.cloudera.com/t5/Community-Articles/Change-Data-Capture-CDC-with-Apache-NiFi-Part-2-of-3/ta-p/246519 Change Data Capture (CDC) with Apache NiFi – Part 3 of 3 https://community.cloudera.com/t5/Community-Articles/Change-Data-Capture-CDC-with-Apache-NiFi-Part-3-of-3/ta-p/246482   ... View more

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

@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