Path Lines of Code client/spotbugs-exclude.xml 56 client/src/main/java/com/epam/eco/kafkamanager/client/RestKafkaManager.java 688 client/src/main/java/com/epam/eco/kafkamanager/client/autoconfigure/ClientSecurityProfiles.java 4 client/src/main/java/com/epam/eco/kafkamanager/client/autoconfigure/DisabledClientSecurityConfiguration.java 13 client/src/main/java/com/epam/eco/kafkamanager/client/autoconfigure/KafkaManagerClientAutoConfiguration.java 163 client/src/main/java/com/epam/eco/kafkamanager/client/autoconfigure/KafkaManagerClientProperties.java 18 client/src/main/java/com/epam/eco/kafkamanager/client/consumer/exec/RestConsumerGroupOffsetResetterTaskExecutor.java 42 client/src/main/java/com/epam/eco/kafkamanager/client/consumer/exec/RestConsumerGroupTopicOffsetFetcherTaskExecutor.java 55 client/src/main/java/com/epam/eco/kafkamanager/client/topic/exec/RestTopicOffsetForTimeFetcherTaskExecutor.java 43 client/src/main/java/com/epam/eco/kafkamanager/client/topic/exec/RestTopicOffsetRangeFetcherTaskExecutor.java 77 client/src/main/java/com/epam/eco/kafkamanager/client/topic/exec/RestTopicPurgerTaskExecutor.java 40 client/src/main/java/com/epam/eco/kafkamanager/client/topic/exec/RestTopicRecordCounterTaskExecutor.java 53 client/src/main/java/com/epam/eco/kafkamanager/client/topic/exec/RestTopicRecordFetcherTaskExecutor.java 42 commons/spotbugs-exclude.xml 33 commons/src/main/java/com/epam/eco/kafkamanager/AbstractSearchCriteria.java 82 commons/src/main/java/com/epam/eco/kafkamanager/AlreadyExistsException.java 15 commons/src/main/java/com/epam/eco/kafkamanager/Authorizer.java 15 commons/src/main/java/com/epam/eco/kafkamanager/BrokerConfigUpdateParams.java 98 commons/src/main/java/com/epam/eco/kafkamanager/BrokerInfo.java 186 commons/src/main/java/com/epam/eco/kafkamanager/BrokerMetadataDeleteParams.java 72 commons/src/main/java/com/epam/eco/kafkamanager/BrokerMetadataKey.java 44 commons/src/main/java/com/epam/eco/kafkamanager/BrokerMetadataUpdateParams.java 132 commons/src/main/java/com/epam/eco/kafkamanager/BrokerRepo.java 8 commons/src/main/java/com/epam/eco/kafkamanager/BrokerSearchCriteria.java 111 commons/src/main/java/com/epam/eco/kafkamanager/ClausesWithHandler.java 11 commons/src/main/java/com/epam/eco/kafkamanager/ConfigValue.java 85 commons/src/main/java/com/epam/eco/kafkamanager/ConsumerGroupDeleteTopicParams.java 87 commons/src/main/java/com/epam/eco/kafkamanager/ConsumerGroupInfo.java 331 commons/src/main/java/com/epam/eco/kafkamanager/ConsumerGroupListSearchCriteria.java 78 commons/src/main/java/com/epam/eco/kafkamanager/ConsumerGroupMemberInfo.java 169 commons/src/main/java/com/epam/eco/kafkamanager/ConsumerGroupMetadataDeleteParams.java 72 commons/src/main/java/com/epam/eco/kafkamanager/ConsumerGroupMetadataKey.java 43 commons/src/main/java/com/epam/eco/kafkamanager/ConsumerGroupMetadataUpdateParams.java 132 commons/src/main/java/com/epam/eco/kafkamanager/ConsumerGroupOffsetResetterTaskExecutor.java 14 commons/src/main/java/com/epam/eco/kafkamanager/ConsumerGroupRepo.java 11 commons/src/main/java/com/epam/eco/kafkamanager/ConsumerGroupSearchCriteria.java 128 commons/src/main/java/com/epam/eco/kafkamanager/ConsumerGroupTopicOffsetFetcherTaskExecutor.java 24 commons/src/main/java/com/epam/eco/kafkamanager/DatePeriod.java 26 commons/src/main/java/com/epam/eco/kafkamanager/EndPointInfo.java 70 commons/src/main/java/com/epam/eco/kafkamanager/EntityType.java 4 commons/src/main/java/com/epam/eco/kafkamanager/FetchMode.java 31 commons/src/main/java/com/epam/eco/kafkamanager/FilterClause.java 34 commons/src/main/java/com/epam/eco/kafkamanager/FilterOperation.java 46 commons/src/main/java/com/epam/eco/kafkamanager/KafkaAdminOperations.java 35 commons/src/main/java/com/epam/eco/kafkamanager/KafkaExtendedAvroDeserializer.java 72 commons/src/main/java/com/epam/eco/kafkamanager/KafkaExtendedDeserializerUtils.java 20 commons/src/main/java/com/epam/eco/kafkamanager/KafkaKmProducer.java 48 commons/src/main/java/com/epam/eco/kafkamanager/KafkaManager.java 69 commons/src/main/java/com/epam/eco/kafkamanager/Metadata.java 152 commons/src/main/java/com/epam/eco/kafkamanager/MetadataAware.java 5 commons/src/main/java/com/epam/eco/kafkamanager/MetadataKey.java 44 commons/src/main/java/com/epam/eco/kafkamanager/MetadataRepo.java 10 commons/src/main/java/com/epam/eco/kafkamanager/MetadataSearchCriteria.java 7 commons/src/main/java/com/epam/eco/kafkamanager/MetadataUpdateListener.java 5 commons/src/main/java/com/epam/eco/kafkamanager/NotFoundException.java 15 commons/src/main/java/com/epam/eco/kafkamanager/OffsetAndMetadataInfo.java 186 commons/src/main/java/com/epam/eco/kafkamanager/OffsetTimeSeries.java 132 commons/src/main/java/com/epam/eco/kafkamanager/PartitionByKeyResolver.java 4 commons/src/main/java/com/epam/eco/kafkamanager/PartitionByKeyResolverImpl.java 8 commons/src/main/java/com/epam/eco/kafkamanager/PartitionInfo.java 142 commons/src/main/java/com/epam/eco/kafkamanager/PermissionCreateParams.java 237 commons/src/main/java/com/epam/eco/kafkamanager/PermissionInfo.java 199 commons/src/main/java/com/epam/eco/kafkamanager/PermissionMetadataDeleteParams.java 172 commons/src/main/java/com/epam/eco/kafkamanager/PermissionMetadataKey.java 124 commons/src/main/java/com/epam/eco/kafkamanager/PermissionMetadataUpdateParams.java 244 commons/src/main/java/com/epam/eco/kafkamanager/PermissionRepo.java 28 commons/src/main/java/com/epam/eco/kafkamanager/PermissionSearchCriteria.java 209 commons/src/main/java/com/epam/eco/kafkamanager/PrincipalPermissionsDeleteParams.java 150 commons/src/main/java/com/epam/eco/kafkamanager/RecordFetchRequest.java 51 commons/src/main/java/com/epam/eco/kafkamanager/ReplicationState.java 4 commons/src/main/java/com/epam/eco/kafkamanager/ResourcePermissionFilter.java 281 commons/src/main/java/com/epam/eco/kafkamanager/ResourcePermissionsDeleteParams.java 39 commons/src/main/java/com/epam/eco/kafkamanager/SearchCriteria.java 4 commons/src/main/java/com/epam/eco/kafkamanager/SecurityContextAdapter.java 22 commons/src/main/java/com/epam/eco/kafkamanager/Statistics.java 49 commons/src/main/java/com/epam/eco/kafkamanager/TopicConfigUpdateParams.java 98 commons/src/main/java/com/epam/eco/kafkamanager/TopicCreateParams.java 184 commons/src/main/java/com/epam/eco/kafkamanager/TopicInfo.java 176 commons/src/main/java/com/epam/eco/kafkamanager/TopicListSearchCriteria.java 113 commons/src/main/java/com/epam/eco/kafkamanager/TopicMetadataDeleteParams.java 72 commons/src/main/java/com/epam/eco/kafkamanager/TopicMetadataKey.java 43 commons/src/main/java/com/epam/eco/kafkamanager/TopicMetadataUpdateParams.java 132 commons/src/main/java/com/epam/eco/kafkamanager/TopicOffsetFetcherTaskExecutor.java 26 commons/src/main/java/com/epam/eco/kafkamanager/TopicOffsetForTimeFetcherTaskExecutor.java 12 commons/src/main/java/com/epam/eco/kafkamanager/TopicOffsetRangeFetcherTaskExecutor.java 25 commons/src/main/java/com/epam/eco/kafkamanager/TopicPartitionsCreateParams.java 87 commons/src/main/java/com/epam/eco/kafkamanager/TopicPurgerTaskExecutor.java 18 commons/src/main/java/com/epam/eco/kafkamanager/TopicRecordCounterTaskExecutor.java 24 commons/src/main/java/com/epam/eco/kafkamanager/TopicRecordFetchParams.java 93 commons/src/main/java/com/epam/eco/kafkamanager/TopicRecordFetcherTaskExecutor.java 13 commons/src/main/java/com/epam/eco/kafkamanager/TopicRepo.java 18 commons/src/main/java/com/epam/eco/kafkamanager/TopicSearchCriteria.java 4 commons/src/main/java/com/epam/eco/kafkamanager/TopicSearchCriteriaImpl.java 368 commons/src/main/java/com/epam/eco/kafkamanager/TransactionInfo.java 182 commons/src/main/java/com/epam/eco/kafkamanager/TransactionMetadataInfo.java 217 commons/src/main/java/com/epam/eco/kafkamanager/TransactionRepo.java 6 commons/src/main/java/com/epam/eco/kafkamanager/TransactionSearchCriteria.java 113 commons/src/main/java/com/epam/eco/kafkamanager/TransactionTimeSeries.java 131 commons/src/main/java/com/epam/eco/kafkamanager/exec/AbstractAsyncStatefullTaskExecutor.java 195 commons/src/main/java/com/epam/eco/kafkamanager/exec/AbstractAsyncTaskExecutor.java 35 commons/src/main/java/com/epam/eco/kafkamanager/exec/AbstractTaskExecutor.java 21 commons/src/main/java/com/epam/eco/kafkamanager/exec/AsyncStatefullTaskExecutor.java 13 commons/src/main/java/com/epam/eco/kafkamanager/exec/AsyncTaskExecutor.java 7 commons/src/main/java/com/epam/eco/kafkamanager/exec/TaskExecutor.java 6 commons/src/main/java/com/epam/eco/kafkamanager/exec/TaskResult.java 135 commons/src/main/java/com/epam/eco/kafkamanager/export/CsvPermissionExporter.java 30 commons/src/main/java/com/epam/eco/kafkamanager/export/GroupKey.java 53 commons/src/main/java/com/epam/eco/kafkamanager/export/GroupedByPrincipalJsonPermissionExporter.java 41 commons/src/main/java/com/epam/eco/kafkamanager/export/GroupedByPrincipalPlainPermissionExporter.java 48 commons/src/main/java/com/epam/eco/kafkamanager/export/GroupedByResourceJsonPermissionExporter.java 40 commons/src/main/java/com/epam/eco/kafkamanager/export/GroupedByResourcePlainPermissionExporter.java 49 commons/src/main/java/com/epam/eco/kafkamanager/export/JsonPermissionExporter.java 34 commons/src/main/java/com/epam/eco/kafkamanager/export/PermissionExporter.java 38 commons/src/main/java/com/epam/eco/kafkamanager/export/PermissionExporterType.java 22 commons/src/main/java/com/epam/eco/kafkamanager/export/PlainPermissionExporter.java 22 commons/src/main/java/com/epam/eco/kafkamanager/logicaltype/Duration.java 48 commons/src/main/java/com/epam/eco/kafkamanager/logicaltype/LogicalTypeEnum.java 28 commons/src/main/java/com/epam/eco/kafkamanager/logicaltype/LogicalTypeFieldAvroConverter.java 34 commons/src/main/java/com/epam/eco/kafkamanager/logicaltype/LogicalTypeFieldConverter.java 35 commons/src/main/java/com/epam/eco/kafkamanager/logicaltype/LogicalTypeSchemaConverter.java 92 commons/src/main/java/com/epam/eco/kafkamanager/logicaltype/converters/LogicalTypeFieldByteBufferToDecimalConverter.java 25 commons/src/main/java/com/epam/eco/kafkamanager/logicaltype/converters/LogicalTypeFieldDurationConverter.java 29 commons/src/main/java/com/epam/eco/kafkamanager/logicaltype/converters/LogicalTypeFieldIntDateConverter.java 24 commons/src/main/java/com/epam/eco/kafkamanager/logicaltype/converters/LogicalTypeFieldOtherAvroConverter.java 30 commons/src/main/java/com/epam/eco/kafkamanager/logicaltype/converters/LogicalTypeFieldTimeMicrosConverter.java 24 commons/src/main/java/com/epam/eco/kafkamanager/logicaltype/converters/LogicalTypeFieldTimeMillisConverter.java 24 commons/src/main/java/com/epam/eco/kafkamanager/logicaltype/converters/LogicalTypeFieldTimestampMicrosConverter.java 24 commons/src/main/java/com/epam/eco/kafkamanager/logicaltype/converters/LogicalTypeFieldTimestampMillisConverter.java 24 commons/src/main/java/com/epam/eco/kafkamanager/logicaltype/converters/LogicalTypeFieldUuidConverter.java 23 commons/src/main/java/com/epam/eco/kafkamanager/repo/AbstractKeyValueRepo.java 4 commons/src/main/java/com/epam/eco/kafkamanager/repo/AbstractValueRepo.java 42 commons/src/main/java/com/epam/eco/kafkamanager/repo/CachedRepo.java 4 commons/src/main/java/com/epam/eco/kafkamanager/repo/KeyValueRepo.java 9 commons/src/main/java/com/epam/eco/kafkamanager/repo/ValueRepo.java 12 commons/src/main/java/com/epam/eco/kafkamanager/rest/helper/PageImplFields.java 13 commons/src/main/java/com/epam/eco/kafkamanager/rest/helper/PageImplJsonDeserializer.java 130 commons/src/main/java/com/epam/eco/kafkamanager/rest/helper/PageImplJsonSerializer.java 87 commons/src/main/java/com/epam/eco/kafkamanager/rest/helper/PageRequestFields.java 8 commons/src/main/java/com/epam/eco/kafkamanager/rest/helper/PageRequestJsonDeserializer.java 49 commons/src/main/java/com/epam/eco/kafkamanager/rest/helper/PageRequestJsonSerializer.java 20 commons/src/main/java/com/epam/eco/kafkamanager/rest/helper/SortJsonDeserializer.java 39 commons/src/main/java/com/epam/eco/kafkamanager/rest/helper/SortJsonSerializer.java 20 commons/src/main/java/com/epam/eco/kafkamanager/rest/helper/SortOrderFields.java 9 commons/src/main/java/com/epam/eco/kafkamanager/rest/helper/SortOrderJsonDeserializer.java 56 commons/src/main/java/com/epam/eco/kafkamanager/rest/helper/SortOrderJsonSerializer.java 21 commons/src/main/java/com/epam/eco/kafkamanager/rest/helper/SpringModule.java 21 commons/src/main/java/com/epam/eco/kafkamanager/rest/request/BrokerConfigRequest.java 31 commons/src/main/java/com/epam/eco/kafkamanager/rest/request/ConsumerGroupOffsetResetRequest.java 40 commons/src/main/java/com/epam/eco/kafkamanager/rest/request/ConsumerGroupTopicOffsetFetchRequest.java 30 commons/src/main/java/com/epam/eco/kafkamanager/rest/request/MetadataRequest.java 39 commons/src/main/java/com/epam/eco/kafkamanager/rest/request/PermissionRequest.java 90 commons/src/main/java/com/epam/eco/kafkamanager/rest/request/TopicConfigRequest.java 31 commons/src/main/java/com/epam/eco/kafkamanager/rest/request/TopicOffsetForTimeFetchRequest.java 38 commons/src/main/java/com/epam/eco/kafkamanager/rest/request/TopicOffsetRangeFetchRequest.java 30 commons/src/main/java/com/epam/eco/kafkamanager/rest/request/TopicPartitionsRequest.java 30 commons/src/main/java/com/epam/eco/kafkamanager/rest/request/TopicPurgeRequest.java 30 commons/src/main/java/com/epam/eco/kafkamanager/rest/request/TopicRecordCountRequest.java 30 commons/src/main/java/com/epam/eco/kafkamanager/rest/request/TopicRecordFetchRequest.java 39 commons/src/main/java/com/epam/eco/kafkamanager/rest/request/TopicRequest.java 71 commons/src/main/java/com/epam/eco/kafkamanager/rest/response/DetailedMessageResponse.java 40 commons/src/main/java/com/epam/eco/kafkamanager/rest/response/MessageResponse.java 34 commons/src/main/java/com/epam/eco/kafkamanager/utils/ConsumerGroupStateComparator.java 29 commons/src/main/java/com/epam/eco/kafkamanager/utils/DateTimeUtils.java 64 commons/src/main/java/com/epam/eco/kafkamanager/utils/KafkaPrincipalComparator.java 15 commons/src/main/java/com/epam/eco/kafkamanager/utils/MapperUtils.java 96 commons/src/main/java/com/epam/eco/kafkamanager/utils/PrettyHtmlMapper.java 140 core/spotbugs-exclude.xml 79 core/src/main/java/com/epam/eco/kafkamanager/core/KafkaAdminOperationsImpl.java 145 core/src/main/java/com/epam/eco/kafkamanager/core/KafkaManagerImpl.java 524 core/src/main/java/com/epam/eco/kafkamanager/core/SecurityContextAdapterImpl.java 29 core/src/main/java/com/epam/eco/kafkamanager/core/authz/PermitAllAuthorizer.java 10 core/src/main/java/com/epam/eco/kafkamanager/core/authz/kafka/KafkaAuthorizer.java 138 core/src/main/java/com/epam/eco/kafkamanager/core/authz/kafka/KafkaAuthorizerConfiguration.java 15 core/src/main/java/com/epam/eco/kafkamanager/core/authz/kafka/KafkaAuthorizerProperties.java 47 core/src/main/java/com/epam/eco/kafkamanager/core/authz/kafka/SimpleAuthorizableRequestContext.java 78 core/src/main/java/com/epam/eco/kafkamanager/core/autoconfigure/KafkaManagerAutoConfiguration.java 168 core/src/main/java/com/epam/eco/kafkamanager/core/autoconfigure/KafkaManagerProperties.java 136 core/src/main/java/com/epam/eco/kafkamanager/core/broker/repo/zk/BrokerOperation.java 4 core/src/main/java/com/epam/eco/kafkamanager/core/broker/repo/zk/ZkBrokerCache.java 196 core/src/main/java/com/epam/eco/kafkamanager/core/broker/repo/zk/ZkBrokerConfigCache.java 167 core/src/main/java/com/epam/eco/kafkamanager/core/broker/repo/zk/ZkBrokerRepo.java 233 core/src/main/java/com/epam/eco/kafkamanager/core/consumer/exec/ConsumerGroupOffsetResetterTaskExecutorImpl.java 36 core/src/main/java/com/epam/eco/kafkamanager/core/consumer/exec/ConsumerGroupTopicOffsetFetcherTaskExecutorImpl.java 46 core/src/main/java/com/epam/eco/kafkamanager/core/consumer/repo/CompositeConsumerGroupRepo.java 103 core/src/main/java/com/epam/eco/kafkamanager/core/consumer/repo/kafka/ClientGroupMetadata.java 45 core/src/main/java/com/epam/eco/kafkamanager/core/consumer/repo/kafka/ClientMemberMetadata.java 40 core/src/main/java/com/epam/eco/kafkamanager/core/consumer/repo/kafka/ClientOffsetAndMetadata.java 29 core/src/main/java/com/epam/eco/kafkamanager/core/consumer/repo/kafka/ConsumerGroupOperation.java 4 core/src/main/java/com/epam/eco/kafkamanager/core/consumer/repo/kafka/ConsumerProtocolUtils.java 20 core/src/main/java/com/epam/eco/kafkamanager/core/consumer/repo/kafka/GroupMetadataAdapter.java 11 core/src/main/java/com/epam/eco/kafkamanager/core/consumer/repo/kafka/KafkaConsumerGroupCache.java 439 core/src/main/java/com/epam/eco/kafkamanager/core/consumer/repo/kafka/KafkaConsumerGroupRepo.java 258 core/src/main/java/com/epam/eco/kafkamanager/core/consumer/repo/kafka/KafkaGroupMetadata.java 59 core/src/main/java/com/epam/eco/kafkamanager/core/consumer/repo/kafka/MemberMetadataAdapter.java 12 core/src/main/java/com/epam/eco/kafkamanager/core/consumer/repo/kafka/OffsetAndMetadataAdapter.java 7 core/src/main/java/com/epam/eco/kafkamanager/core/consumer/repo/kafka/ServerGroupMetadata.java 48 core/src/main/java/com/epam/eco/kafkamanager/core/consumer/repo/kafka/ServerGroupMetadataDecoder.java 33 core/src/main/java/com/epam/eco/kafkamanager/core/consumer/repo/kafka/ServerMemberMetadata.java 42 core/src/main/java/com/epam/eco/kafkamanager/core/consumer/repo/kafka/ServerOffsetAndMetadata.java 32 core/src/main/java/com/epam/eco/kafkamanager/core/consumer/repo/zk/ZkConsumerGroupCache.java 370 core/src/main/java/com/epam/eco/kafkamanager/core/consumer/repo/zk/ZkConsumerGroupRepo.java 196 core/src/main/java/com/epam/eco/kafkamanager/core/metadata/repo/kafka/KafkaMetadataRepo.java 147 core/src/main/java/com/epam/eco/kafkamanager/core/permission/repo/zk/PermissionOperation.java 4 core/src/main/java/com/epam/eco/kafkamanager/core/permission/repo/zk/ZkAclCache.java 262 core/src/main/java/com/epam/eco/kafkamanager/core/permission/repo/zk/ZkPermissionRepo.java 289 core/src/main/java/com/epam/eco/kafkamanager/core/spring/AsyncStartingBean.java 8 core/src/main/java/com/epam/eco/kafkamanager/core/spring/AsyncStartingBeanProcessor.java 72 core/src/main/java/com/epam/eco/kafkamanager/core/topic/exec/TopicOffsetForTimeFetcherTaskExecutorImpl.java 26 core/src/main/java/com/epam/eco/kafkamanager/core/topic/exec/TopicOffsetRangeFetcherTaskExecutorImpl.java 86 core/src/main/java/com/epam/eco/kafkamanager/core/topic/exec/TopicPurgerTaskExecutorImpl.java 56 core/src/main/java/com/epam/eco/kafkamanager/core/topic/exec/TopicRecordCounterTaskExecutorImpl.java 36 core/src/main/java/com/epam/eco/kafkamanager/core/topic/exec/TopicRecordFetcherTaskExecutorImpl.java 101 core/src/main/java/com/epam/eco/kafkamanager/core/topic/repo/zk/TopicOperation.java 4 core/src/main/java/com/epam/eco/kafkamanager/core/topic/repo/zk/ZkTopicCache.java 341 core/src/main/java/com/epam/eco/kafkamanager/core/topic/repo/zk/ZkTopicConfigCache.java 160 core/src/main/java/com/epam/eco/kafkamanager/core/topic/repo/zk/ZkTopicRepo.java 319 core/src/main/java/com/epam/eco/kafkamanager/core/txn/repo/kafka/KafkaTransactionCache.java 236 core/src/main/java/com/epam/eco/kafkamanager/core/txn/repo/kafka/KafkaTransactionRepo.java 179 core/src/main/java/com/epam/eco/kafkamanager/core/txn/repo/kafka/TransactionProjection.java 159 core/src/main/java/com/epam/eco/kafkamanager/core/utils/CuratorUtils.java 20 core/src/main/java/com/epam/eco/kafkamanager/core/utils/InitWaitingTreeCacheStarter.java 45 core/src/main/java/com/epam/eco/kafkamanager/core/utils/PageUtils.java 35 core/src/main/java/com/epam/eco/kafkamanager/core/utils/RetriableZookeeperFactory.java 20 core/src/main/java/com/epam/eco/kafkamanager/core/utils/ZKPathUtils.java 15 docker/docker-compose-all.yaml 38 docker/docker-compose-cp.yaml 43 rest/spotbugs-exclude.xml 16 rest/src/main/java/com/epam/eco/kafkamanager/rest/KafkaManagerRestApplication.java 9 rest/src/main/java/com/epam/eco/kafkamanager/rest/config/AuthenticationLogFilter.java 32 rest/src/main/java/com/epam/eco/kafkamanager/rest/config/DisabledWebSecurityConfig.java 21 rest/src/main/java/com/epam/eco/kafkamanager/rest/config/JwtAuthConverter.java 47 rest/src/main/java/com/epam/eco/kafkamanager/rest/config/KafkaManagerRestConfiguration.java 29 rest/src/main/java/com/epam/eco/kafkamanager/rest/config/KafkaManagerRestProperties.java 12 rest/src/main/java/com/epam/eco/kafkamanager/rest/config/KeycloakWebSecurityConfig.java 41 rest/src/main/java/com/epam/eco/kafkamanager/rest/config/OpenApiConfig.java 24 rest/src/main/java/com/epam/eco/kafkamanager/rest/config/WebSecurityProfiles.java 5 rest/src/main/java/com/epam/eco/kafkamanager/rest/controller/BrokerController.java 74 rest/src/main/java/com/epam/eco/kafkamanager/rest/controller/ConsumerGroupController.java 80 rest/src/main/java/com/epam/eco/kafkamanager/rest/controller/EnumController.java 49 rest/src/main/java/com/epam/eco/kafkamanager/rest/controller/PermissionController.java 201 rest/src/main/java/com/epam/eco/kafkamanager/rest/controller/RestResponseEntityExceptionHandler.java 74 rest/src/main/java/com/epam/eco/kafkamanager/rest/controller/TaskController.java 194 rest/src/main/java/com/epam/eco/kafkamanager/rest/controller/TopicController.java 137 rest/src/main/java/com/epam/eco/kafkamanager/rest/controller/TransactionController.java 39 rest/src/main/resources/application-auth-keycloak.yaml 72 udmetrics/spotbugs-exclude.xml 11 udmetrics/src/main/java/com/epam/eco/kafkamanager/udmetrics/Metric.java 6 udmetrics/src/main/java/com/epam/eco/kafkamanager/udmetrics/ScheduleCalculatedMetric.java 4 udmetrics/src/main/java/com/epam/eco/kafkamanager/udmetrics/ScheduleCalculatedMetricExecutor.java 49 udmetrics/src/main/java/com/epam/eco/kafkamanager/udmetrics/UDMetric.java 103 udmetrics/src/main/java/com/epam/eco/kafkamanager/udmetrics/UDMetricConfig.java 97 udmetrics/src/main/java/com/epam/eco/kafkamanager/udmetrics/UDMetricConfigRepo.java 11 udmetrics/src/main/java/com/epam/eco/kafkamanager/udmetrics/UDMetricConfigSearchCriteria.java 94 udmetrics/src/main/java/com/epam/eco/kafkamanager/udmetrics/UDMetricCreator.java 14 udmetrics/src/main/java/com/epam/eco/kafkamanager/udmetrics/UDMetricManager.java 19 udmetrics/src/main/java/com/epam/eco/kafkamanager/udmetrics/UDMetricManagerImpl.java 194 udmetrics/src/main/java/com/epam/eco/kafkamanager/udmetrics/UDMetricSearchCriteria.java 120 udmetrics/src/main/java/com/epam/eco/kafkamanager/udmetrics/UDMetricType.java 47 udmetrics/src/main/java/com/epam/eco/kafkamanager/udmetrics/autoconfigure/UDMetricManagerAutoConfiguration.java 34 udmetrics/src/main/java/com/epam/eco/kafkamanager/udmetrics/autoconfigure/UDMetricManagerProperties.java 19 udmetrics/src/main/java/com/epam/eco/kafkamanager/udmetrics/config/repo/kafka/KafkaUDMetricConfigRepo.java 156 udmetrics/src/main/java/com/epam/eco/kafkamanager/udmetrics/config/repo/kafka/KafkaUDMetricConfigRepoConfiguration.java 11 udmetrics/src/main/java/com/epam/eco/kafkamanager/udmetrics/config/repo/kafka/KafkaUDMetricConfigRepoProperties.java 12 udmetrics/src/main/java/com/epam/eco/kafkamanager/udmetrics/library/ConsumerGroupLagUDMCreator.java 58 udmetrics/src/main/java/com/epam/eco/kafkamanager/udmetrics/library/ConsumerGroupPartitionLagMetric.java 105 udmetrics/src/main/java/com/epam/eco/kafkamanager/udmetrics/library/TopicOffsetIncreaseUDMCreator.java 21 udmetrics/src/main/java/com/epam/eco/kafkamanager/udmetrics/library/TopicPartitionOffsetIncreaseMetric.java 101 udmetrics/src/main/java/com/epam/eco/kafkamanager/udmetrics/utils/MeterTagComparator.java 22 udmetrics/src/main/java/com/epam/eco/kafkamanager/udmetrics/utils/MeterTagsComparator.java 33 udmetrics/src/main/java/com/epam/eco/kafkamanager/udmetrics/utils/MetricComparator.java 17 ui/spotbugs-exclude.xml 135 ui/src/main/java/com/epam/eco/kafkamanager/ui/BuildInfo.java 41 ui/src/main/java/com/epam/eco/kafkamanager/ui/GlobalErrorController.java 38 ui/src/main/java/com/epam/eco/kafkamanager/ui/GlobalModelEnrichingInterceptor.java 58 ui/src/main/java/com/epam/eco/kafkamanager/ui/KafkaManagerUiApplication.java 14 ui/src/main/java/com/epam/eco/kafkamanager/ui/LogoutListener.java 8 ui/src/main/java/com/epam/eco/kafkamanager/ui/brokers/BrokerController.java 130 ui/src/main/java/com/epam/eco/kafkamanager/ui/brokers/BrokerInfoWrapper.java 68 ui/src/main/java/com/epam/eco/kafkamanager/ui/common/ConfigEntryWrapper.java 76 ui/src/main/java/com/epam/eco/kafkamanager/ui/config/AuthenticationLogFilter.java 31 ui/src/main/java/com/epam/eco/kafkamanager/ui/config/BaseWebSecurityConfig.java 57 ui/src/main/java/com/epam/eco/kafkamanager/ui/config/DataCatalogUrlTemplate.java 7 ui/src/main/java/com/epam/eco/kafkamanager/ui/config/DisabledWebSecurityConfig.java 24 ui/src/main/java/com/epam/eco/kafkamanager/ui/config/ExternalToolTemplate.java 22 ui/src/main/java/com/epam/eco/kafkamanager/ui/config/GoogleBaseWebSecurityConfig.java 22 ui/src/main/java/com/epam/eco/kafkamanager/ui/config/GrafanaUrlTemplate.java 19 ui/src/main/java/com/epam/eco/kafkamanager/ui/config/HeaderReplacement.java 23 ui/src/main/java/com/epam/eco/kafkamanager/ui/config/KafkaManagerUiConfiguration.java 70 ui/src/main/java/com/epam/eco/kafkamanager/ui/config/KafkaManagerUiProperties.java 46 ui/src/main/java/com/epam/eco/kafkamanager/ui/config/KafkaManagerUiPropertiesValidator.java 59 ui/src/main/java/com/epam/eco/kafkamanager/ui/config/KeycloakBaseWebSecurityConfig.java 99 ui/src/main/java/com/epam/eco/kafkamanager/ui/config/PropertiesInitializer.java 10 ui/src/main/java/com/epam/eco/kafkamanager/ui/config/SchemaCatalogTemplate.java 21 ui/src/main/java/com/epam/eco/kafkamanager/ui/config/TopicBrowser.java 106 ui/src/main/java/com/epam/eco/kafkamanager/ui/config/UrlTemplate.java 24 ui/src/main/java/com/epam/eco/kafkamanager/ui/config/WebSecurityProfiles.java 6 ui/src/main/java/com/epam/eco/kafkamanager/ui/config/producer/KafkaManagerByteArrayProducer.java 8 ui/src/main/java/com/epam/eco/kafkamanager/ui/config/producer/KmKafkaProducerConfiguration.java 47 ui/src/main/java/com/epam/eco/kafkamanager/ui/consumers/ConsumerGroupController.java 142 ui/src/main/java/com/epam/eco/kafkamanager/ui/consumers/ConsumerGroupInfoWrapper.java 89 ui/src/main/java/com/epam/eco/kafkamanager/ui/consumers/ConsumerGroupOffsetResetterController.java 93 ui/src/main/java/com/epam/eco/kafkamanager/ui/consumers/ResetGroupOffsetsParams.java 132 ui/src/main/java/com/epam/eco/kafkamanager/ui/consumers/ResettableOffsetRange.java 21 ui/src/main/java/com/epam/eco/kafkamanager/ui/consumers/model/ConsumerGroupRecordModel.java 72 ui/src/main/java/com/epam/eco/kafkamanager/ui/consumers/model/ConsumerGroupTableModel.java 65 ui/src/main/java/com/epam/eco/kafkamanager/ui/home/HomeController.java 15 ui/src/main/java/com/epam/eco/kafkamanager/ui/metrics/MetricsStateController.java 28 ui/src/main/java/com/epam/eco/kafkamanager/ui/metrics/udm/ConsumerGroupLagUDMController.java 83 ui/src/main/java/com/epam/eco/kafkamanager/ui/metrics/udm/TopicOffsetIncreaseUDMController.java 73 ui/src/main/java/com/epam/eco/kafkamanager/ui/metrics/udm/UDMAbstractController.java 14 ui/src/main/java/com/epam/eco/kafkamanager/ui/metrics/udm/UDMetricWrapper.java 79 ui/src/main/java/com/epam/eco/kafkamanager/ui/metrics/udm/UDMetricsController.java 48 ui/src/main/java/com/epam/eco/kafkamanager/ui/permissions/PermissionController.java 137 ui/src/main/java/com/epam/eco/kafkamanager/ui/permissions/PermissionInfoWrapper.java 48 ui/src/main/java/com/epam/eco/kafkamanager/ui/permissions/ResourcePermissionController.java 314 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/TopicConsumerGroupOffsets.java 99 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/TopicController.java 283 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/TopicInfoWrapper.java 223 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/browser/AvroRecordValueTabulator.java 107 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/browser/AvroRecordValuesExtractor.java 69 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/browser/KafkaRecordRepublisher.java 10 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/browser/KafkaRecordRepublisherImpl.java 116 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/browser/NoopRecordValueTabulator.java 30 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/browser/ProtobufRecordValueTabulator.java 106 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/browser/RecordSchema.java 49 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/browser/RecordValueTabulator.java 8 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/browser/ReplacementType.java 16 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/browser/TabularRecords.java 438 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/browser/ToTabularRecordsConverter.java 68 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/browser/TopicBrowseParams.java 342 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/browser/TopicBrowserController.java 332 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/browser/filter/FilterClauseCompositeNoopPredicate.java 9 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/browser/filter/FilterClauseCompositePredicate.java 104 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/browser/handlers/FilterOperationEnum.java 31 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/browser/handlers/FilterOperationHandler.java 37 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/browser/handlers/FilterOperationJsonHandler.java 126 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/browser/handlers/FilterOperationMapHandler.java 117 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/browser/handlers/FilterOperationStringHandler.java 28 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/browser/handlers/FilterOperationTombstoneHandler.java 36 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/browser/handlers/FilterOperationUtils.java 57 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/browser/pedicates/FilterClauseAbstractKeyPredicate.java 36 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/browser/pedicates/FilterClauseAbstractValuePredicate.java 23 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/browser/pedicates/FilterClauseAvroKeyPredicate.java 13 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/browser/pedicates/FilterClauseAvroValuePredicate.java 35 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/browser/pedicates/FilterClauseHeaderPredicate.java 34 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/browser/pedicates/FilterClauseJsonKeyPredicate.java 13 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/browser/pedicates/FilterClauseJsonValuePredicate.java 32 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/browser/pedicates/FilterClauseNoopPredicate.java 9 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/browser/pedicates/FilterClauseStringKeyPredicate.java 13 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/browser/pedicates/FilterClauseStringValuePredicate.java 32 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/browser/pedicates/FilterClauseTombstonePredicate.java 27 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/export/JsonTopicExporter.java 41 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/export/PlainTopicExporter.java 38 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/export/TopicExporter.java 40 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/export/TopicExporterType.java 17 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/model/ExternalToolModel.java 52 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/model/TopicInfoToModelMapper.java 70 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/model/TopicRecordModel.java 145 ui/src/main/java/com/epam/eco/kafkamanager/ui/topics/model/TopicTableModel.java 65 ui/src/main/java/com/epam/eco/kafkamanager/ui/transactions/TransactionController.java 56 ui/src/main/java/com/epam/eco/kafkamanager/ui/transactions/TransactionInfoWrapper.java 100 ui/src/main/java/com/epam/eco/kafkamanager/ui/transactions/TransactionMetadataInfoWrapper.java 48 ui/src/main/java/com/epam/eco/kafkamanager/ui/utils/CollapsedCollectionIterable.java 105 ui/src/main/java/com/epam/eco/kafkamanager/ui/utils/ComboBoxModel.java 12 ui/src/main/java/com/epam/eco/kafkamanager/ui/utils/HeaderUtils.java 68 ui/src/main/java/com/epam/eco/kafkamanager/ui/utils/MetadataWrapper.java 41 ui/src/main/java/com/epam/eco/kafkamanager/ui/utils/RedirectUrlUtils.java 9 ui/src/main/java/com/epam/eco/kafkamanager/ui/utils/SchemaSubjectUtils.java 42 ui/src/main/java/com/epam/eco/kafkamanager/ui/utils/UiUtils.java 21 ui/src/main/java/com/epam/eco/kafkamanager/ui/utils/WorkerUtils.java 21 ui/src/main/resources/application-google.yaml 93 ui/src/main/resources/application-keycloak.yaml 118 ui/src/main/resources/application.yaml 84 ui/src/main/resources/static/bootstrap/css/bootstrap-grid.css 3865 ui/src/main/resources/static/bootstrap/css/bootstrap-grid.rtl.css 3865 ui/src/main/resources/static/bootstrap/css/bootstrap-icons.css 1388 ui/src/main/resources/static/bootstrap/css/bootstrap-reboot.css 346 ui/src/main/resources/static/bootstrap/css/bootstrap-reboot.rtl.css 352 ui/src/main/resources/static/bootstrap/css/bootstrap-utilities.css 3634 ui/src/main/resources/static/bootstrap/css/bootstrap-utilities.rtl.css 3630 ui/src/main/resources/static/bootstrap/js/bootstrap.bundle.js 4863 ui/src/main/resources/static/bootstrap/js/bootstrap.esm.js 3447 ui/src/main/resources/static/components/browse-filter/browse-filter.css 46 ui/src/main/resources/static/components/browse-filter/browse-filter.js 251 ui/src/main/resources/static/components/collapsed-panel/collapsed-panel-chevron.js 44 ui/src/main/resources/static/components/collapsed-panel/collapsed-panel.js 55 ui/src/main/resources/static/components/copy-text/copy-text.js 5 ui/src/main/resources/static/components/footer/footer.css 26 ui/src/main/resources/static/components/header/header-menu-item.css 20 ui/src/main/resources/static/components/header/header-menu.css 60 ui/src/main/resources/static/components/header/header.css 34 ui/src/main/resources/static/components/header/index.js 25 ui/src/main/resources/static/components/loading-modal/loading-modal.js 17 ui/src/main/resources/static/components/query-param-filter/query-param-filter.css 58 ui/src/main/resources/static/components/query-param-filter/query-param-filter.js 371 ui/src/main/resources/static/data-tables/fixedColumns.dataTables.min.css 1 ui/src/main/resources/static/faq/browse-filter-faq.html 33 ui/src/main/resources/static/faq/consumer-group-list/filter-faq.html 133 ui/src/main/resources/static/faq/topic-browser/browse-filter-faq.html 63 ui/src/main/resources/static/faq/topic-browser/fetch-faq.html 51 ui/src/main/resources/static/faq/topic-browser/limit-faq.html 19 ui/src/main/resources/static/faq/topic-browser/offsets-faq.html 79 ui/src/main/resources/static/faq/topic-browser/timeout-faq.html 9 ui/src/main/resources/static/faq/topic-browser/timestamp-fetch-faq.html 41 ui/src/main/resources/static/faq/topic-list/filter-faq.html 105 ui/src/main/resources/static/faq/topic-list/toolbar-faq.html 27 ui/src/main/resources/static/js/ui_lib.js 271 ui/src/main/resources/static/js/ui_lib_browser.js 80 ui/src/main/resources/static/jsonview/jquery.jsonview.css 50 ui/src/main/resources/static/moment/moment-2.26.js 4699 ui/src/main/resources/static/styles/css/bootstrap.epam.custom.css 598 ui/src/main/resources/static/styles/css/copy-text.css 38 ui/src/main/resources/static/styles/css/main.css 129 ui/src/main/resources/static/styles/index.css 89 ui/src/main/resources/templates/broker.html 110 ui/src/main/resources/templates/broker_config_update.html 110 ui/src/main/resources/templates/broker_metadata.html 89 ui/src/main/resources/templates/brokers.html 84 ui/src/main/resources/templates/consumer_group.html 236 ui/src/main/resources/templates/consumer_group_metadata.html 87 ui/src/main/resources/templates/consumer_group_offset_resetter.html 135 ui/src/main/resources/templates/consumer_groups.html 166 ui/src/main/resources/templates/error.html 52 ui/src/main/resources/templates/error_internal.html 48 ui/src/main/resources/templates/metrics_state.html 18 ui/src/main/resources/templates/permission_create.html 111 ui/src/main/resources/templates/permissions.html 248 ui/src/main/resources/templates/resource_permissions.html 306 ui/src/main/resources/templates/resource_permissions_metadata.html 93 ui/src/main/resources/templates/templates.html 344 ui/src/main/resources/templates/topic.html 515 ui/src/main/resources/templates/topic_browser.html 945 ui/src/main/resources/templates/topic_config_update.html 111 ui/src/main/resources/templates/topic_create.html 144 ui/src/main/resources/templates/topic_metadata.html 87 ui/src/main/resources/templates/topic_partitions_create.html 58 ui/src/main/resources/templates/topics.html 262 ui/src/main/resources/templates/transaction.html 112 ui/src/main/resources/templates/transactions.html 144 ui/src/main/resources/templates/udmetric_consumer_group_lag.html 82 ui/src/main/resources/templates/udmetric_topic_offset_increase.html 59 ui/src/main/resources/templates/udmetrics.html 182 ui/src/main/resources/templates/udmetrics_disabled.html 18