private String bootstrapServer = "localhost:9092";
private String applicationId = "popular";
private String inputTopic = "words";
- private String outputTopic = "popular";
+ private String outputTopic = "countings";
private Integer commitInterval;
private Integer cacheMaxBytes;
}