package de.juplo.kafka.wordcount.counter;
-import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
-@AllArgsConstructor(staticName = "of")
-@NoArgsConstructor
@Data
-@JsonIgnoreProperties(ignoreUnknown = true)
+@NoArgsConstructor
+@AllArgsConstructor(staticName = "of")
public class Word
{
- private String user;
- private String word;
+ private final String type = CounterStreamProcessor.TYPE;
+ private String channel;
+ private String key;
}