+
+ await("Expexted converted data")
+ .atMost(Duration.ofSeconds(10))
+ .untilAsserted(() ->
+ {
+ assertThat(consumer.received.get(USER)).hasSize(1);
+ RecordingResult recordingResult = objectMapper.readValue(
+ consumer.received.get(USER).get(0),
+ RecordingResult.class);
+ assertThat(recordingResult.getUsername()).isEqualTo(USER);
+ assertThat(recordingResult.getSentence()).isEqualTo(SENTENCE);
+ assertThat(recordingResult.getTopic()).isEqualTo(TOPIC_OUT);
+ assertThat(recordingResult.getPartition()).isBetween(0, PARTITIONS - 1);
+ assertThat(recordingResult.getStatus()).isNull();
+ assertThat(recordingResult.getError()).isNull();
+ });