@Alvin Jin Also, let's keep in mind that Confluent Schema Registry is for Avro and for Kafka only. Hortonworks Schema Registry is meant to manage much more than Avro for Kafka. Stay tuned. Hortonworks Schema Registry is meant for all consumers from HDF and HDP platforms, not only for Kafka and will gradually support all commonly used formats. ... View more

Correct, you would have to implement a ConfluentSchemaRegistry controller service for NiFi. ... View more

@Alvin Jin My suggestion would be use something like: https://regex101.com/ You can enter your regex and sample test you want to run it against. Matt ... View more

Thanks @smanjee Good job! I am looking forward Part II ... View more

Hi @Greg Keys, Thanks for the post. Row filtering works based on the column values which is not in the end. But I am not sure how to filter the rows based on the last column value. Can you please let me know. Thanks ... View more

No problem, glad it was helpful 🙂 If you are reaching the login screen, then it means your browser is not forwarding your credentials to NiFi. You could try setting the negotiate properties to just "myhost.de" instead of the full url with port. Another thing to look at might be the domain being used by your KDC... In this example I was using nifi.apache.org as the domain, so I had to add a mapping in /etc/hosts to map nifi.apache.org to localhost so I could use nifi.apache.org in my browser to access my local NiFi. If you are accessing myhost.de to get to your NiFi instance, but that isn't the domain in your KDC, then it won't line up and probably won't forward your credentials. ... View more

In 1.0.0 the difference will be that the cache server has to run on all nodes because there is no more concept of choosing where the controller service runs (since there is no master). The cache client would be configured to point to the cache server on one of the nodes, so if that node goes down there is still no automatic failover at this point. ... View more

Hi @jsequeiros After setting up site-to-site properties on all nodes, the fetchSftp works as expected. Both worker nodes are involved in file fetching. How do we distribute tasks evenly among workers? since I found sometimes one worker took all the files. Sometimes, one took 3, while the other one took 1. I have total 4 test files. Thanks. ... View more