Vereinfachte Version der auf Spring Kafka basierenden Implementierung
[demos/kafka/training] / src / main / java / de / juplo / kafka / MessageAddNumber.java
1 package de.juplo.kafka;
2
3 import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
4 import lombok.Data;
5
6
7 @Data
8 @JsonIgnoreProperties(ignoreUnknown = true)
9 public class MessageAddNumber extends Message
10 {
11   private Integer next;
12
13
14   @Override
15   public Type getType()
16   {
17     return Type.ADD;
18   }
19 }