code: public void setSystemName(String systemName) {
  		this.systemName = systemName;
  		for (SamzaSystemStream systemStream:systemStreams) {
  			systemStream.setSystem(systemName);
  		}
  	}
docs: /*
  System name (Kafka)