public Partition getChangelogPartition() {
    return changelogPartition;
  }
Returns the {@link Partition} used for all changelogs for this task.
@return changelog partition for this task
samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java