@Override
  public boolean equals(Object o) {
    if (this == o) {
      return true;
    }
    if (o == null || getClass() != o.getClass()) {
      return false;
    }

    TaskModel taskModel = (TaskModel) o;

    if (!changelogPartition.equals(taskModel.changelogPartition)) {
      return false;
    }
    if (!systemStreamPartitions.equals(taskModel.systemStreamPartitions)) {
      return false;
    }
    if (!taskName.equals(taskModel.taskName)) {
      return false;
    }

    if (!taskMode.equals(taskModel.taskMode)) {
      return false;
    }

    return true;
  }
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