Das README.sh führt die Reaktion auf eine Poison Pill vor

[demos/kafka/training] / src / main / java / de / juplo / kafka / MessageAddNumber.java

package de.juplo.kafka;

import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
import lombok.Data;


@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public class MessageAddNumber extends Message
{
  private Integer next;


  @Override
  public Type getType()
  {
    return Type.ADD;
  }
}