@RenoldSingh, have any of the replies helped resolve your issue? If so, please mark the appropriate reply as the solution, as it will make it easier for others to find the answer in the future.  ... View more

Thank you very much for your help. ... View more

@MR_KD Has the reply helped resolve your issue? If so, please mark the appropriate reply as the solution, as it will make it easier for others to find the answer in the future. Thanks. ... View more

@hegdemahendra  You also need to be careful with some rest-api request as they may generate reports that are held in NiFi heap until a rest-api call is made to remove them.  Doing similar actions directly from the UI handles the multiple calls needed automatically.  So calls like these can slowly eat away at the NiFi heap impacting performance until a restart.  Provenance queries would be an example of this. Unrelated note:  NiFi Variable registry has been deprecated in favor of NiFi Parameters now.  The Variable registry functionality has been officially removed starting with the latest NiFi 2.0.0-M1 release.   If you found any of the suggestions/solutions provided helped you with your issue, please take a moment to login and click "Accept as Solution" on one or more of them that helped. Thank you, Matt ... View more

@I_Mesh01 This error is stating that your topic schema and flink schema do not match.   I cant see much above related to the shape of the data or the schema, but this is what you should be looking at.   Conflict in data/column types, missing data, etc, will result in the deserialization errors. ... View more

@matdulgi The drivers are able to be downloaded from public internet and you are able to use them accordingly.   https://www.cloudera.com/downloads/connectors/impala/odbc/2-7-0.html https://www.cloudera.com/downloads/connectors/impala/jdbc/2-6-32.html.html     ... View more

CHeck out this link @joseomjr shared in another post:   https://cwiki.apache.org/confluence/display/NIFI/Release+Notes#ReleaseNotes-Version2.0.0-M1   And here is a great blog from Pierre Villard:   https://medium.com/cloudera-inc/getting-ready-for-apache-nifi-2-0-5a5e6a67f450     Nifi 2.0 brings python native, where jython was very limited library set. ... View more

It works.    However  processor was spit "record has failed the validation on broker and hence will be rejected" with fail when if "complete,delete" set clean up policy on SMM.  It works after change cleanup policy to "delete"     Thanks    ... View more

@joseomjr Is on to the right solution here.  Your regex statement should match "kafka.topic" not "${kafka.topic}".     A quick test in regex101.com confirms "kafka\.topic" should match. ... View more