mirror of
https://github.com/OtusTeam/Spring.git
synced 2026-05-30 10:50:42 +00:00
spring-35-36-cloud
This commit is contained in:
+1
-1
@@ -18,7 +18,7 @@ public class ErrorHandler implements ErrorWebExceptionHandler {
|
||||
private static final Logger log = LoggerFactory.getLogger(ErrorHandler.class);
|
||||
|
||||
@Override
|
||||
public Mono<Void> handle(@NonNull ServerWebExchange serverWebExchange, @NonNull Throwable thr) {
|
||||
public @NonNull Mono<Void> handle(@NonNull ServerWebExchange serverWebExchange, @NonNull Throwable thr) {
|
||||
var bufferFactory = serverWebExchange.getResponse().bufferFactory();
|
||||
var response = serverWebExchange.getResponse();
|
||||
response.getHeaders().setContentType(MediaType.APPLICATION_JSON);
|
||||
|
||||
@@ -10,6 +10,6 @@ springCloudVersion=2023.0.3
|
||||
|
||||
sonarlint=4.2.4
|
||||
spotless=6.25.0
|
||||
jib=3.4.3
|
||||
jib=3.4.5
|
||||
# -------Versions--------
|
||||
logbackEncoder=8.0
|
||||
|
||||
+1
-2
@@ -38,8 +38,7 @@ public class LogProducer {
|
||||
|
||||
kafkaProducer = new KafkaProducer<>(props);
|
||||
|
||||
var shutdownHook = new Thread(this::close);
|
||||
Runtime.getRuntime().addShutdownHook(shutdownHook);
|
||||
Runtime.getRuntime().addShutdownHook(new Thread(this::close));
|
||||
}
|
||||
|
||||
public void send(String value, Consumer<String> errorCallback) {
|
||||
|
||||
@@ -0,0 +1,14 @@
|
||||
dependencies {
|
||||
implementation(project(":kafka-log-appender"))
|
||||
implementation("net.logstash.logback:logstash-logback-encoder")
|
||||
|
||||
implementation ("org.springframework.boot:spring-boot-starter-web")
|
||||
implementation("org.springframework.boot:spring-boot-starter-actuator")
|
||||
implementation("io.micrometer:micrometer-registry-prometheus")
|
||||
|
||||
implementation("org.springframework.cloud:spring-cloud-starter-config")
|
||||
implementation("org.springframework.cloud:spring-cloud-starter-netflix-eureka-client")
|
||||
|
||||
implementation("io.micrometer:micrometer-tracing-bridge-otel") // bridges the Micrometer Observation API to OpenTelemetry.
|
||||
implementation("io.opentelemetry:opentelemetry-exporter-zipkin") // reports traces to Zipkin.
|
||||
}
|
||||
Reference in New Issue
Block a user