package de.juplo.kafka.chat.backend.domain;
import lombok.Getter;
-import org.apache.kafka.common.TopicPartition;
public class ShardNotOwnedException extends IllegalStateException
{
@Getter
- private final TopicPartition topicPartition;
+ private final int shard;
- public ShardNotOwnedException(TopicPartition topicPartition)
+ public ShardNotOwnedException(int shard)
{
- super("This instance does not own the shard for " + topicPartition);
- this.topicPartition = topicPartition;
+ super("This instance does not own the shard " + shard);
+ this.shard = shard;
}
}