import de.juplo.kafka.wordcount.counter.TestCounter;
import de.juplo.kafka.wordcount.counter.TestWord;
import de.juplo.kafka.wordcount.query.TestRanking;
-import de.juplo.kafka.wordcount.query.TestUser;
+import de.juplo.kafka.wordcount.query.TestStats;
import lombok.extern.slf4j.Slf4j;
import org.apache.kafka.streams.TestInputTopic;
import org.apache.kafka.streams.TestOutputTopic;
public static final String OUT = "TEST-OUT";
static TopologyTestDriver testDriver;
- static MultiValueMap<TestUser, TestRanking> receivedMessages = new LinkedMultiValueMap<>();
+ static MultiValueMap<TestStats, TestRanking> receivedMessages = new LinkedMultiValueMap<>();
@BeforeAll
jsonSerializer(TestWord.class, true),
jsonSerializer(TestCounter.class,false));
- TestOutputTopic<TestUser, TestRanking> out = testDriver.createOutputTopic(
+ TestOutputTopic<TestStats, TestRanking> out = testDriver.createOutputTopic(
OUT,
new JsonDeserializer()
- .copyWithType(TestUser.class)
+ .copyWithType(TestStats.class)
.ignoreTypeHeaders(),
new JsonDeserializer()
.copyWithType(TestRanking.class)
@DisplayName("Assert the expected number of messages")
@Test
- public void testExpectedNumberOfMessagesForUsers()
+ public void testExpectedNumberOfMessages()
{
- TestData.assertExpectedNumberOfMessagesForUsers(receivedMessages);
+ TestData.assertExpectedNumberOfMessages(receivedMessages);
}
@DisplayName("Assert the expected final output messages")
@Test
- public void testExpectedLastMessagesForUSers()
+ public void testExpectedLastMessages()
{
- TestData.assertExpectedLastMessagesForUsers(receivedMessages);
+ TestData.assertExpectedLastMessages(receivedMessages);
}
@DisplayName("Assert the expected state in the state-store")
@Test
public void testExpectedState()
{
- KeyValueStore<User, Ranking> store = testDriver.getKeyValueStore(STORE_NAME);
+ KeyValueStore<Stats, Ranking> store = testDriver.getKeyValueStore(STORE_NAME);
TestData.assertExpectedState(store);
}