I'm able to make GET calls just fine, though the NiFi docs for PUT/POST are a bit cryptic. As I understand it, we need to call POST on /process-groups/{id}/process-groups to create a process group before we can upload a template. However, after reading through the API docs, I can't seem to figure out what is required in the body (API docs suggest everything is optional). I'll repeatedly get "Process group details must be specified" despite trying different requests. Anyone happen to have examples of creating a process group, preferably up to and including uploading a template? I was using the following resources from Andrew and Matthew, but unfortunately not compatible with the new API. https://github.com/aperepel/nifi-api-deploy https://github.com/mattyb149/nifi-client ... View more

I have data that I want to serialize, and I currently have it laid out like so: val mySerializer: AvroSnapshotSerializer = schemaRegistryClient.getDefaultSerializer(...) val myObj: GenericData.Record = new GenericData.Record(...) val myMetadata: SchemaMetadata = new SchemaMetadata.Builder("NameOfMySchema") .schemaGroup(...) .description(...) .etc. val serializedObj = mySerializer.serializer(myObj, myMetadata) Assuming that I've already registered my schema (by hand or in another application), is there a way to use the Serializer's serialize() method without having to build the metadata all over again? Can I retrieve the a SchemaMetadata object from, say, the SchemaVersionInfo that I get with the following? schemaRegistryClient.getLatestSchemaVersionInfo("NameOfMySchema") Having looked through the reference material and source code, I can't seem to find a way to get a copy of the metadata from without building it anew. Thanks! Edgar ... View more

I’m working with NiFi WebSocket processors, and I’d like to update connected clients as data makes its way through the flow. Is there a way to register WS connections in such a way where once data makes its way to a PutWebSocket processor, I can push to all registered clients automatically? Is this outside the scope of what NiFi may have been intended for? Thanks! ... View more