removed deprecated methods

Author: dmytro-landiak

application/src/main/java/org/thingsboard/mqtt/broker/controller/AdminController.java

@@ -165,13 +165,6 @@ public User getAdminById(@PathVariable(USER_ID) String strUserId) throws Thingsb
         return filterSensitiveUserData(checkUserId(userId));
     }
 
-    @PreAuthorize("hasAuthority('SYS_ADMIN')")
-    @PostMapping(value = "/user")
-    @Deprecated(since = "2.2.0", forRemoval = true)
-    public User saveAdminUser(@RequestBody User user) throws ThingsboardException {
-        return filterSensitiveUserData(checkNotNull(userService.saveUser(user)));
-    }
-
     @PreAuthorize("hasAuthority('SYS_ADMIN')")
     @PostMapping(value = "/securitySettings")
     public SecuritySettings saveSecuritySettings(@RequestBody SecuritySettings securitySettings) throws ThingsboardException {

common/dao-api/src/main/java/org/thingsboard/mqtt/broker/dao/client/MqttClientCredentialsService.java

@@ -43,9 +43,6 @@ public interface MqttClientCredentialsService {
 
     PageData<ShortMqttClientCredentials> getCredentials(PageLink pageLink);
 
-    @Deprecated(since = "2.2.0", forRemoval = true)
-    PageData<MqttClientCredentials> getFullCredentials(PageLink pageLink);
-
     PageData<ShortMqttClientCredentials> getCredentialsV2(ClientCredentialsQuery query);
 
     Optional<MqttClientCredentials> getCredentialsById(UUID id);

common/queue/src/main/java/org/thingsboard/mqtt/broker/queue/TbQueueAdmin.java

@@ -25,7 +25,6 @@
 import org.thingsboard.mqtt.broker.common.data.queue.KafkaTopic;
 
 import java.util.Collection;
-import java.util.List;
 import java.util.Map;
 import java.util.concurrent.ExecutionException;
 
@@ -49,9 +48,6 @@ public interface TbQueueAdmin {
 
     PageData<KafkaTopic> getTopics(PageLink pageLink);
 
-    @Deprecated(since = "2.2.0", forRemoval = true)
-    List<String> getBrokerServiceIds();
-
     PageData<KafkaConsumerGroup> getConsumerGroups(PageLink pageLink);
 
     void deleteOldConsumerGroups(String consumerGroupPrefix, String serviceId, long currentCgSuffix);

common/queue/src/main/java/org/thingsboard/mqtt/broker/queue/kafka/TbKafkaAdmin.java

@@ -78,8 +78,6 @@ public class TbKafkaAdmin implements TbQueueAdmin {
     private boolean enableTopicDeletion;
     @Value("${queue.kafka.kafka-prefix:}")
     private String kafkaPrefix;
-    @Value("${queue.kafka.client-session-event-response.topic-prefix:tbmq.client.session.event.response}")
-    private String clientSessionEventRespTopicPrefix;
     @Value("${queue.kafka.admin.command-timeout:30}")
     private int kafkaAdminCommandTimeout;
 
@@ -298,21 +296,6 @@ public PageData<KafkaTopic> getTopics(PageLink pageLink) {
         }
     }
 
-    @Override
-    public List<String> getBrokerServiceIds() {
-        try {
-            Set<String> topics = client.listTopics().names().get();
-            return topics
-                    .stream()
-                    .filter(topic -> topic.startsWith(kafkaPrefix + clientSessionEventRespTopicPrefix))
-                    .map(topic -> topic.replace(kafkaPrefix + clientSessionEventRespTopicPrefix + ".", ""))
-                    .collect(Collectors.toList());
-        } catch (InterruptedException | ExecutionException e) {
-            log.warn("Failed to get broker names", e);
-            throw new RuntimeException(e);
-        }
-    }
-
     @Override
     public PageData<KafkaConsumerGroup> getConsumerGroups(PageLink pageLink) {
         try {

dao/src/main/java/org/thingsboard/mqtt/broker/dao/client/MqttClientCredentialsServiceImpl.java

@@ -163,13 +163,6 @@ public PageData<ShortMqttClientCredentials> getCredentials(PageLink pageLink) {
         return toShortMqttClientCredentialsPageData(mqttClientCredentialsDao.findAll(pageLink));
     }
 
-    @Override
-    public PageData<MqttClientCredentials> getFullCredentials(PageLink pageLink) {
-        log.trace("Executing getFullCredentials, pageLink [{}]", pageLink);
-        validatePageLink(pageLink);
-        return mqttClientCredentialsDao.findAll(pageLink);
-    }
-
     @Override
     public PageData<ShortMqttClientCredentials> getCredentialsV2(ClientCredentialsQuery query) {
         log.trace("Executing getCredentialsV2, query [{}]", query);