public int getReplicationFactor() {
      return replicationFactor;
    }
@param replicationFactor The number of replicas for the changelog stream
@param kafkaProperties The kafka specific properties that need to be used for changelog stream creation
samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemAdmin.java