@Override
  public Host filter(final KsqlHostInfo host) {
    if (host.host().equals(activeHost.host()) && host.port() == activeHost.port()) {
      return Host.include(host);
    }
    return Host.exclude(host, "Host is not the active host for this partition.");
  }
@Test
  public void shouldFilterActive() {
    // Given:

    // When:
    final Host filterActive = activeHostFilter.filter(activeHost);
    final Host filterStandby = activeHostFilter.filter(standByHost);

    // Then:
    assertThat(filterActive.isSelected(), is(true));
    assertThat(filterStandby.isSelected(), is(false));
    assertThat(filterStandby.getReasonNotSelected(), is("Host is not the active host for this partition."));
  }