Skip to content

Instantly share code, notes, and snippets.


push-gists/ Secret

Last active Aug 2, 2016
What would you like to do?
Add a stream of maps
new MapStreamAdapter(new MapStream() {
public void onTransformationException(String topicPath, JSON value, Exception e) {
// Handle errors
public void onValue(
String topicPath,
TopicSpecification topicSpecification,
Map<String, Object> oldValue,
Map<String, Object> newValue) {
// Do something awesome
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment