-package de.juplo.kafka.wordcount.counter;
+package de.juplo.kafka.wordcount.popular;
import lombok.Getter;
import org.springframework.boot.context.properties.ConfigurationProperties;
-@ConfigurationProperties("juplo.wordcount.counter")
+@ConfigurationProperties("juplo.wordcount.popular")
@Getter
@Setter
@ToString
-public class CounterApplicationProperties
+public class PopularApplicationProperties
{
private String bootstrapServer = "localhost:9092";
- private String applicationId = "counter";
+ private String applicationId = "popular";
private String inputTopic = "words";
- private String outputTopic = "countings";
+ private String outputTopic = "popular";
private Integer commitInterval;
private Integer cacheMaxBytes;
}