+++ /dev/null
-package de.juplo.kafka.wordcount.recorder;
-
-import com.fasterxml.jackson.annotation.JsonInclude;
-import lombok.Value;
-
-import static com.fasterxml.jackson.annotation.JsonInclude.Include.NON_NULL;
-
-
-@Value(staticConstructor = "of")
-public class RecordingResult
-{
- @JsonInclude(NON_NULL) private final String username;
- @JsonInclude(NON_NULL) private final String sentence;
- @JsonInclude(NON_NULL) private final String topic;
- @JsonInclude(NON_NULL) private final Integer partition;
- @JsonInclude(NON_NULL) private final Long offset;
- @JsonInclude(NON_NULL) private final Integer status;
- @JsonInclude(NON_NULL) private final String error;
-}