public void start() {
    commandTopicBackup.initialize();
    commandConsumer.assign(Collections.singleton(commandTopicPartition));
  }
@Test
  public void shouldInitializeCommandTopicBackup() {
    // When
    commandTopic.start();

    // Then
    verify(commandTopicBackup, times(1)).initialize();
  }