1 package de.juplo.kafka.wordcount.recorder;
3 import com.fasterxml.jackson.annotation.JsonInclude;
6 import static com.fasterxml.jackson.annotation.JsonInclude.Include.NON_NULL;
9 @Value(staticConstructor = "of")
10 public class RecordingResult
12 @JsonInclude(NON_NULL) private final String username;
13 @JsonInclude(NON_NULL) private final String sentence;
14 @JsonInclude(NON_NULL) private final String topic;
15 @JsonInclude(NON_NULL) private final Integer partition;
16 @JsonInclude(NON_NULL) private final Long offset;
17 @JsonInclude(NON_NULL) private final Integer status;
18 @JsonInclude(NON_NULL) private final String error;