Skip to content

Commit b005d39

Browse files
committed
deprecation
1 parent db88824 commit b005d39

File tree

1 file changed

+4
-5
lines changed

1 file changed

+4
-5
lines changed

api/src/main/java/io/kafbat/ui/service/OffsetsResetService.java

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -2,9 +2,8 @@
22

33
import static java.util.stream.Collectors.toMap;
44
import static java.util.stream.Collectors.toSet;
5-
import static org.apache.kafka.common.ConsumerGroupState.DEAD;
6-
import static org.apache.kafka.common.ConsumerGroupState.EMPTY;
7-
5+
import static org.apache.kafka.common.GroupState.DEAD;
6+
import static org.apache.kafka.common.GroupState.EMPTY;
87
import com.google.common.base.Preconditions;
98
import io.kafbat.ui.exception.NotFoundException;
109
import io.kafbat.ui.exception.ValidationException;
@@ -104,13 +103,13 @@ private Mono<ReactiveAdminClient> checkGroupCondition(KafkaCluster cluster, Stri
104103
.filter(cgs -> cgs.containsKey(groupId))
105104
.map(cgs -> cgs.get(groupId))
106105
.flatMap(cg -> {
107-
if (!Set.of(DEAD, EMPTY).contains(cg.state())) {
106+
if (!Set.of(DEAD, EMPTY).contains(cg.groupState())) {
108107
return Mono.error(
109108
new ValidationException(
110109
String.format(
111110
"Group's offsets can be reset only if group is inactive,"
112111
+ " but group is in %s state",
113-
cg.state()
112+
cg.groupState()
114113
)
115114
)
116115
);

0 commit comments

Comments
 (0)