--- /dev/null
+package de.juplo.kafka.wordcount.users;
+
+import com.fasterxml.jackson.annotation.JsonInclude;
+import lombok.Value;
+
+import static com.fasterxml.jackson.annotation.JsonInclude.Include.NON_NULL;
+
+
+@Value(staticConstructor = "of")
+public class UsersResult
+{
+ @JsonInclude(NON_NULL) private final String username;
+ @JsonInclude(NON_NULL) private final User user;
+ @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;
+}