MySQL CDC solution with nifi

2015-10-13 Thread xmlking
I am researching to implement Change Data Capture(CDC) solution by observing MySQL binlogs and routing that data through NiFi to detect inserts , updates and deletes and finally storing/sync the data into NoSQL(MongoDB) and HDFS. For this use case the data in source system is normalized (OLTP)

Re: "External" extensions

2015-11-01 Thread xmlking
How about maintaining a registry like npm https://www.npmjs.com or https://github.com/jspm/registry where individuals host their modules on github and users can discover them via registry? Sent from my iPad > On Nov 1, 2015, at 10:35 AM, Joe Witt wrote: > > " but raises several questions, al

Re: "External" extensions

2015-11-02 Thread xmlking
In nodejs/npm world, each module has package.json, which declaratively indicate which node version and other external modules it depends on. Similarly I am thinking Nar modules can declare which version of JVM and NiFi it depends on and also which other modules it depends on. NPM ( NiFi Package

Re: [GitHub] nifi pull request: NIFI-1218 upgraded Kafka to 0.9.0.0 client API

2015-12-16 Thread xmlking
May be we can create getKafka2 for 0.9.0.0, leaving original form backward compatibility. I will try new consumer API tomorrow and share here. My concern with old consumer API is, it depends on zookeeper and worried, I may have to open multiple ports on firewall as described here http://mai

Re: Error: is not the most recent version of this flow file within this session

2015-12-22 Thread xmlking
Thanks Richard. I will test it tomorrow. Sumo Sent from my iPad > On Dec 21, 2015, at 11:25 PM, Richard Miskin wrote: > > Hi Sumanth, > > I think you need to assign the return of putAllAttributes() to ff. A new > FlowFile is created as part of that call. > > Cheers, > Richard > > On Tuesday,

Re: State Management

2016-01-11 Thread xmlking
Some open source projects are using Hazelcast's distributed map for state management. It provides standard Java map API. http://docs.hazelcast.org/docs/3.5/manual/html/map.html Sumo Sent from my iPad > On Jan 11, 2016, at 5:37 AM, Mark Payne wrote: > > In case any of you are following along h

Git NiFi processor

2016-02-17 Thread xmlking
I have an usecase where I have to pull some configuration files from Git repository and store them into a server directory, whenever files are updated via webhooks.[automated deployment] Checking if anybody build custom processor to pull files from Git. By the way, it would be nice if NiFi UI d

Re: Scripted controllers

2016-02-21 Thread xmlking
Was planing to upgrade my websocket processor/controller to 0.5.1. Just checking, so that I don't have to build if controller scripting is in roadmap, Nothing important Thanks Sumo > On Feb 20, 2016, at 10:40 AM, Joe Witt wrote: > > Hello Sumo > > https://issues.apache.org/jira/browse/N