diff --git a/src/main/java/io/strimzi/kafka/bridge/ConsumerInstanceId.java b/src/main/java/io/strimzi/kafka/bridge/ConsumerInstanceId.java index 8af282e9..223045e7 100644 --- a/src/main/java/io/strimzi/kafka/bridge/ConsumerInstanceId.java +++ b/src/main/java/io/strimzi/kafka/bridge/ConsumerInstanceId.java @@ -30,12 +30,10 @@ public boolean equals(Object obj) { return true; } - if (!(obj instanceof ConsumerInstanceId)) { + if (!(obj instanceof ConsumerInstanceId other)) { return false; } - ConsumerInstanceId other = (ConsumerInstanceId) obj; - if (groupId != null && !groupId.equals(other.groupId)) { return false; }