From 6074f6d1089a8a40944fff2c7b1f15d6e1c04108 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Tue, 25 Jun 2024 06:23:33 +0200 Subject: [PATCH] WIP --- src/main/java/de/juplo/kafka/wordcount/stats/Key.java | 2 +- .../de/juplo/kafka/wordcount/stats/StatisticsType.java | 7 +++++++ 2 files changed, 8 insertions(+), 1 deletion(-) create mode 100644 src/main/java/de/juplo/kafka/wordcount/stats/StatisticsType.java diff --git a/src/main/java/de/juplo/kafka/wordcount/stats/Key.java b/src/main/java/de/juplo/kafka/wordcount/stats/Key.java index ab88ee6..afe1514 100644 --- a/src/main/java/de/juplo/kafka/wordcount/stats/Key.java +++ b/src/main/java/de/juplo/kafka/wordcount/stats/Key.java @@ -6,6 +6,6 @@ import lombok.Data; @Data public class Key { - private String type; + private StatisticsType type; private String channel; } diff --git a/src/main/java/de/juplo/kafka/wordcount/stats/StatisticsType.java b/src/main/java/de/juplo/kafka/wordcount/stats/StatisticsType.java new file mode 100644 index 0000000..c8f6e09 --- /dev/null +++ b/src/main/java/de/juplo/kafka/wordcount/stats/StatisticsType.java @@ -0,0 +1,7 @@ +package de.juplo.kafka.wordcount.stats; + +public enum StatisticsType +{ + POPULAR, + SPEAKERS +} -- 2.20.1