1 package de.juplo.kafka.chat.backend.domain;
4 import org.apache.kafka.common.TopicPartition;
7 public class ShardNotOwnedException extends IllegalStateException
10 private final TopicPartition topicPartition;
13 public ShardNotOwnedException(TopicPartition topicPartition)
15 super("This instance does not own the shard for " + topicPartition);
16 this.topicPartition = topicPartition;