jayarampradhan

- Run the below Vagrant to bring up the necessary nifi, active mq, zookeper and kafka
- Create a dummy que name "test" in activemq
- Create a dummy topic "test" in kafka
- start nifi
- navigate to localhost:8080/nifi/
- From Dashboard configure the source and sink processor defination

- https://nifi.apache.org/docs/nifi-docs/html/administration-guide.html#clustering
- http://ingest.tips/2014/12/22/getting-started-with-apache-nifi/

jayarampradhan

# -*- mode: ruby -*-
# vi: set ft=ruby :

# All Vagrant configuration is done below. The "2" in Vagrant.configure
# configures the configuration version (we support older styles for
# backwards compatibility). Please don't change it unless you know what
# you're doing.
Vagrant.configure(2) do |config|

  config.vm.provision "shell", inline: "echo Hello"

jayarampradhan

# Dockerizing MongoDB: 3.1 Dockerfile for building MongoDB 3.1 images
# Based on centos:centos7, installs MongoDB

FROM centos:centos7

MAINTAINER Jayaram Pradhan <jayaram.pradhan@uimirror.com>

# Set up mongodb yum repo entry
# https://www.liquidweb.com/kb/how-to-install-mongodb-on-centos-6/
RUN echo -e "\

stuart-marks

import java.util.*;
import java.util.function.*;
import java.util.stream.*;

import static java.util.stream.Collectors.*;
import static java.util.Comparator.*;

/**
 * http://stackoverflow.com/questions/22845574/how-to-dynamically-do-filtering-in-java-8
 *