deprecation

Author: yeikel

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

@@ -2,8 +2,6 @@
 
 import static java.util.stream.Collectors.toMap;
 import static java.util.stream.Collectors.toSet;
-import static org.apache.kafka.common.ConsumerGroupState.DEAD;
-import static org.apache.kafka.common.ConsumerGroupState.EMPTY;
 
 import com.google.common.base.Preconditions;
 import io.kafbat.ui.exception.NotFoundException;
@@ -18,6 +16,7 @@
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.kafka.clients.admin.OffsetSpec;
+import org.apache.kafka.common.GroupState;
 import org.apache.kafka.common.TopicPartition;
 import org.springframework.stereotype.Component;
 import reactor.core.publisher.Mono;
@@ -104,13 +103,13 @@ private Mono<ReactiveAdminClient> checkGroupCondition(KafkaCluster cluster, Stri
                 .filter(cgs -> cgs.containsKey(groupId))
                 .map(cgs -> cgs.get(groupId))
                 .flatMap(cg -> {
-                  if (!Set.of(DEAD, EMPTY).contains(cg.state())) {
+                  if (!Set.of(GroupState.DEAD, GroupState.EMPTY).contains(cg.groupState())) {
                     return Mono.error(
                         new ValidationException(
                             String.format(
                                 "Group's offsets can be reset only if group is inactive,"
                                     + " but group is in %s state",
-                                cg.state()
+                                cg.groupState()
                             )
                         )
                     );