Skip to content

Commit

Permalink
Update of unit tests to use KRaft - part 8 (#10441)
Browse files Browse the repository at this point in the history
Signed-off-by: Jakub Scholz <[email protected]>
  • Loading branch information
scholzj authored Aug 15, 2024
1 parent dacdc85 commit b46da22
Show file tree
Hide file tree
Showing 4 changed files with 1,983 additions and 805 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -265,6 +265,7 @@ private void basicCheck() {
assertThat(Kafka.isReady().test(k), is(true));
assertThat(k.getStatus().getKafkaMetadataVersion(), startsWith(VERSIONS.defaultVersion().metadataVersion() + "-IV"));
assertThat(k.getStatus().getKafkaVersion(), is(VERSIONS.defaultVersion().version()));
assertThat(k.getStatus().getOperatorLastSuccessfulVersion(), is(KafkaAssemblyOperator.OPERATOR_VERSION));
assertThat(k.getStatus().getKafkaMetadataState().toValue(), is("KRaft"));
assertThat(k.getStatus().getKafkaNodePools().stream().map(UsedNodePoolStatus::getName).toList(), is(List.of("brokers", "controllers")));
}
Expand Down
Loading

0 comments on commit b46da22

Please sign in to comment.