0ct0pu5/kafka-ui
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

checkstyle fixed

Browse source
This commit is contained in:
iliax 2023-05-23 00:03:09 +04:00
parent e2975e3bea
commit 13bcaf037a
4 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
kafka-ui-api/src/main/java/com/provectus/kafka/ui/controller/MessagesController.java
View file

@ -93,8 +93,6 @@ public class MessagesController extends AbstractController implements MessagesAp
contextBuilder.auditActions(AuditAction.VIEW);
}
var context = contextBuilder.build();
seekType = seekType != null ? seekType : SeekTypeDTO.BEGINNING;
seekDirection = seekDirection != null ? seekDirection : SeekDirectionDTO.FORWARD;
filterQueryType = filterQueryType != null ? filterQueryType : MessageFilterTypeDTO.STRING_CONTAINS;
@ -112,6 +110,7 @@ public class MessagesController extends AbstractController implements MessagesAp
)
);
var context = contextBuilder.build();
return accessControlService.validateAccess(context)
.then(job)
.doOnEach(sig -> auditService.audit(context, sig));

3
kafka-ui-api/src/main/java/com/provectus/kafka/ui/service/MessagesService.java
View file

@ -149,7 +149,8 @@ public class MessagesService {
}
}
public static KafkaProducer<byte[], byte[]> createProducer(KafkaCluster cluster, Map<String, Object> additionalProps) {
public static KafkaProducer<byte[], byte[]> createProducer(KafkaCluster cluster,
Map<String, Object> additionalProps) {
Properties properties = new Properties();
SslPropertiesUtil.addKafkaSslProperties(cluster.getOriginalProperties().getSsl(), properties);
properties.putAll(cluster.getProperties());

4
kafka-ui-api/src/main/java/com/provectus/kafka/ui/service/audit/AuditService.java
View file

@ -1,6 +1,6 @@
package com.provectus.kafka.ui.service.audit;
import static com.provectus.kafka.ui.service.MessagesService.*;
import static com.provectus.kafka.ui.service.MessagesService.createProducer;
import com.google.common.annotations.VisibleForTesting;
import com.provectus.kafka.ui.config.ClustersProperties;
@ -104,7 +104,7 @@ public class AuditService implements Closeable {
}
/**
* @return true if topic created/existing and producing can be enabled
* return true if topic created/existing and producing can be enabled.
*/
private static boolean createTopicIfNeeded(KafkaCluster cluster,
ReactiveAdminClient ac,

2
kafka-ui-api/src/test/java/com/provectus/kafka/ui/service/audit/AuditServiceTest.java
View file

@ -86,7 +86,7 @@ class AuditServiceTest {
}
@Test
void setsLoggerIfConsoleLoggingEnabled(){
void setsLoggerIfConsoleLoggingEnabled() {
var auditProps = new ClustersProperties.AuditProperties();
auditProps.setConsoleAuditEnabled(true);
clustersProperties.setAudit(auditProps);