projects
/
demos
/
kafka
/
chat
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
NEU
[demos/kafka/chat]
/
src
/
main
/
java
/
de
/
juplo
/
kafka
/
chat
/
backend
/
domain
/
ShardNotOwnedException.java
diff --git
a/src/main/java/de/juplo/kafka/chat/backend/domain/ShardNotOwnedException.java
b/src/main/java/de/juplo/kafka/chat/backend/domain/ShardNotOwnedException.java
index
452f26d
..
3b63833
100644
(file)
--- a/
src/main/java/de/juplo/kafka/chat/backend/domain/ShardNotOwnedException.java
+++ b/
src/main/java/de/juplo/kafka/chat/backend/domain/ShardNotOwnedException.java
@@
-1,18
+1,17
@@
package de.juplo.kafka.chat.backend.domain;
import lombok.Getter;
package de.juplo.kafka.chat.backend.domain;
import lombok.Getter;
-import org.apache.kafka.common.TopicPartition;
public class ShardNotOwnedException extends IllegalStateException
{
@Getter
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
;
}
}
}
}