Skip to content

Commit

Permalink
Add tests
Browse files Browse the repository at this point in the history
  • Loading branch information
@JakobEdding
JakobEdding committed Apr 11, 2024
1 parent 7461741 commit 011347e
Show file tree
Hide file tree
Showing 3 changed files with 180 additions and 0 deletions.
60 changes: 60 additions & 0 deletions ...sts-junit4/src/test/java/com/bakdata/fluent_kafka_streams_tests/junit4/WordCountTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -244,4 +244,64 @@ public void shouldBeDoneAfterSingleWord() {
public void shouldDoNothingOnEmptyInput() {
this.testTopology.streamOutput().expectNoMoreRecord().and().expectNoMoreRecord().toBeEmpty();
}

@Test
public void shouldConvertStreamOutputToList() {
this.testTopology.input()
.add("bla")
.add("blub")
.add("bla");

final List<ProducerRecord<String, Long>> outputs = this.testTopology.streamOutput()
.withSerde(Serdes.String(), Serdes.Long())
.toList();

assertThat(outputs)
.extracting(ProducerRecord::key)
.containsExactly("bla", "blub", "bla");
assertThat(outputs)
.extracting(ProducerRecord::value)
.containsExactly(1L, 1L, 2L);
}

@Test
public void shouldConvertTableOutputToList() {
this.testTopology.input()
.add("bla")
.add("blub")
.add("bla");

final List<ProducerRecord<String, Long>> outputs = this.testTopology.tableOutput()
.withSerde(Serdes.String(), Serdes.Long())
.toList();

assertThat(outputs)
.extracting(ProducerRecord::key)
.containsExactly("bla", "blub");
assertThat(outputs)
.extracting(ProducerRecord::value)
.containsExactly(2L, 1L);
}

@Test
public void shouldConvertEmptyStreamOutputToEmptyList() {
final List<ProducerRecord<String, Long>> outputs = this.testTopology.streamOutput()
.withSerde(Serdes.String(), Serdes.Long())
.toList();

assertThat(outputs)
.isInstanceOf(List.class)
.isEmpty();
}

@Test
public void shouldConvertEmptyTableOutputToEmptyList() {
final List<ProducerRecord<String, Long>> outputs = this.testTopology.tableOutput()
.withSerde(Serdes.String(), Serdes.Long())
.toList();

assertThat(outputs)
.isInstanceOf(List.class)
.isEmpty();
}
}
60 changes: 60 additions & 0 deletions ...sts-junit5/src/test/java/com/bakdata/fluent_kafka_streams_tests/junit5/WordCountTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -244,4 +244,64 @@ void shouldBeDoneAfterSingleWord() {
void shouldDoNothingOnEmptyInput() {
this.testTopology.streamOutput().expectNoMoreRecord().and().expectNoMoreRecord().toBeEmpty();
}

@Test
void shouldConvertStreamOutputToList() {
this.testTopology.input()
.add("bla")
.add("blub")
.add("bla");

final List<ProducerRecord<String, Long>> outputs = this.testTopology.streamOutput()
.withSerde(Serdes.String(), Serdes.Long())
.toList();

assertThat(outputs)
.extracting(ProducerRecord::key)
.containsExactly("bla", "blub", "bla");
assertThat(outputs)
.extracting(ProducerRecord::value)
.containsExactly(1L, 1L, 2L);
}

@Test
void shouldConvertTableOutputToList() {
this.testTopology.input()
.add("bla")
.add("blub")
.add("bla");

final List<ProducerRecord<String, Long>> outputs = this.testTopology.tableOutput()
.withSerde(Serdes.String(), Serdes.Long())
.toList();

assertThat(outputs)
.extracting(ProducerRecord::key)
.containsExactly("bla", "blub");
assertThat(outputs)
.extracting(ProducerRecord::value)
.containsExactly(2L, 1L);
}

@Test
void shouldConvertEmptyStreamOutputToEmptyList() {
final List<ProducerRecord<String, Long>> outputs = this.testTopology.streamOutput()
.withSerde(Serdes.String(), Serdes.Long())
.toList();

assertThat(outputs)
.isInstanceOf(List.class)
.isEmpty();
}

@Test
void shouldConvertEmptyTableOutputToEmptyList() {
final List<ProducerRecord<String, Long>> outputs = this.testTopology.tableOutput()
.withSerde(Serdes.String(), Serdes.Long())
.toList();

assertThat(outputs)
.isInstanceOf(List.class)
.isEmpty();
}
}
60 changes: 60 additions & 0 deletions ...fka-streams-tests/src/test/java/com/bakdata/fluent_kafka_streams_tests/WordCountTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -387,4 +387,64 @@ void shouldBeDoneAfterSingleWord() {
void shouldDoNothingOnEmptyInput() {
this.testTopology.streamOutput().expectNoMoreRecord().and().expectNoMoreRecord().toBeEmpty();
}

@Test
void shouldConvertStreamOutputToList() {
this.testTopology.input()
.add("bla")
.add("blub")
.add("bla");

final List<ProducerRecord<String, Long>> outputs = this.testTopology.streamOutput()
.withSerde(Serdes.String(), Serdes.Long())
.toList();

assertThat(outputs)
.extracting(ProducerRecord::key)
.containsExactly("bla", "blub", "bla");
assertThat(outputs)
.extracting(ProducerRecord::value)
.containsExactly(1L, 1L, 2L);
}

@Test
void shouldConvertTableOutputToList() {
this.testTopology.input()
.add("bla")
.add("blub")
.add("bla");

final List<ProducerRecord<String, Long>> outputs = this.testTopology.tableOutput()
.withSerde(Serdes.String(), Serdes.Long())
.toList();

assertThat(outputs)
.extracting(ProducerRecord::key)
.containsExactly("bla", "blub");
assertThat(outputs)
.extracting(ProducerRecord::value)
.containsExactly(2L, 1L);
}

@Test
void shouldConvertEmptyStreamOutputToEmptyList() {
final List<ProducerRecord<String, Long>> outputs = this.testTopology.streamOutput()
.withSerde(Serdes.String(), Serdes.Long())
.toList();

assertThat(outputs)
.isInstanceOf(List.class)
.isEmpty();
}

@Test
void shouldConvertEmptyTableOutputToEmptyList() {
final List<ProducerRecord<String, Long>> outputs = this.testTopology.tableOutput()
.withSerde(Serdes.String(), Serdes.Long())
.toList();

assertThat(outputs)
.isInstanceOf(List.class)
.isEmpty();
}
}

0 comments on commit 011347e

Please sign in to comment.