NiFiClient client = null;
try {
final ClientFactory<NiFiClient> nifiClientFactory = getContext().getNiFiClientFactory();
client = new NiFiClientFactory().createClient(???);
} catch (MissingOptionException e) {
e.printStackTrace();
}
try {
String processGroup = "2129ff11-2b41-39ff-4b96-d0b7243e94b9";
VariableRegistryEntity entity = client.getProcessGroupClient().getVariables(processGroup);
Set<VariableEntity> varSet = entity.getVariableRegistry().getVariables();
Map<String, String> processorVariables = new HashMap<>();
varSet.forEach(variable -> {
VariableDTO dto = variable.getVariable();
logger_.debug("Key: " + dto.getName());
logger_.debug("Value: " + dto.getValue());
processorVariables.put(dto.getName(), dto.getValue());
});
} catch (NiFiClientException ex) {
ex.printStackTrace();
}