Upgrade version to 0.2.0-SNAPSHOT.
Using commons version 0.2.0-SNAPSHOT.
Index operation implemented.
Stop index stream operation scheleton.
Added configuration command-line parameters for integration tests, this way you can specify the streaming zookeeper and kafka configuration when running the integration tests.
Increase the ack time-out
SaveToCassandra method
Reduced flakiness and check streaming status at the end.