diff --git a/clearing-parent/backend-api/src/main/java/ru/spcex/clearing/backendapi/controller/test/KafkaApiController.java b/clearing-parent/backend-api/src/main/java/ru/spcex/clearing/backendapi/controller/test/KafkaApiController.java index 335e0025f..026302e97 100644 --- a/clearing-parent/backend-api/src/main/java/ru/spcex/clearing/backendapi/controller/test/KafkaApiController.java +++ b/clearing-parent/backend-api/src/main/java/ru/spcex/clearing/backendapi/controller/test/KafkaApiController.java @@ -49,6 +49,7 @@ public class KafkaApiController { JavaType requestType = json.getTypeFactory().constructSimpleType(parameterType, null); Object obj = json.readValue(bankAccountNewAction.getJson(), requestType); Long idOfBaseRequestMessage = kafkaSender.sendRequestToQueue(bankAccountNewAction.getTopicName(), obj); + log.debug("Test message to topic {} with request id={}", bankAccountNewAction.getTopicName(), idOfBaseRequestMessage); return "success: baseRequest.id = " + idOfBaseRequestMessage; } diff --git a/clearing-parent/backend-api/src/main/java/ru/spcex/clearing/backendapi/service/impl/OperatorImpl.java b/clearing-parent/backend-api/src/main/java/ru/spcex/clearing/backendapi/service/impl/OperatorImpl.java index 009d24485..d23513302 100644 --- a/clearing-parent/backend-api/src/main/java/ru/spcex/clearing/backendapi/service/impl/OperatorImpl.java +++ b/clearing-parent/backend-api/src/main/java/ru/spcex/clearing/backendapi/service/impl/OperatorImpl.java @@ -82,6 +82,7 @@ public class OperatorImpl implements IOperator { saveRequestToStorage(destination, request); Future send = kafka.send(new ProducerRecord<>(destination, request)); send.get(); + log.debug("Request id={} by user {} send to queue \"{}\". Action: {}", request.getId(), request.getUserId(), destination, iAction); return new QueueSuccessResponse(request.getActionType(), request.getId()); } @@ -101,13 +102,15 @@ public class OperatorImpl implements IOperator { saveRequestToStorage(destination, request); Future send = kafka.send(new ProducerRecord<>(destination, request)); send.get(); + log.debug("Request id={} by user {} send to queue \"{}\". Action: {}", request.getId(), userId, destination, iAction); return new QueueSuccessResponse(request.getActionType(), request.getId()); } private void saveRequestToStorage(String destination, BaseRequest request) { Imdg requestStorage = imdgProvider.getImdg(IMDGDistributedNames.Map_RequestInfo, RequestInfo.class); RequestInfo requestInfo = RequestInfo.create(request.getId()); - requestStorage.insert(requestInfo); + Long storeId = requestStorage.insert(requestInfo); + log.trace("Request id={} saved as RequestInfo with id={}", request.getId(), storeId); } private void throwValidate(String destination, IAction iAction) { diff --git a/clearing-parent/backend-api/src/main/resources/application.properties b/clearing-parent/backend-api/src/main/resources/application.properties index bbbcc6022..29cf01fe5 100644 --- a/clearing-parent/backend-api/src/main/resources/application.properties +++ b/clearing-parent/backend-api/src/main/resources/application.properties @@ -23,6 +23,10 @@ backend-api.kafka-consumer.auto-offset-reset=latest backend-api.kafka-consumer.linger-ms=1 backend-api.kafka-consumer.buffer-memory=33554432 backend-api.security.authorization-disabled=false +#access logs, sample +#server.tomcat.accesslog.directory=logs +#server.tomcat.accesslog.enabled=true +#server.tomcat.accesslog.pattern=%h %l %u %t \"%r\" %>s %b ##keycloak ##keycloak.auth-server-url=http://10.200.200.147:8080/ ##keycloak.realm=master