diff --git a/src/main/java/io/strimzi/kafka/bridge/http/HttpAdminBridgeEndpoint.java b/src/main/java/io/strimzi/kafka/bridge/http/HttpAdminBridgeEndpoint.java index 5cfd0c71..9e7ce581 100644 --- a/src/main/java/io/strimzi/kafka/bridge/http/HttpAdminBridgeEndpoint.java +++ b/src/main/java/io/strimzi/kafka/bridge/http/HttpAdminBridgeEndpoint.java @@ -148,9 +148,7 @@ public void doGetTopic(RoutingContext routingContext) { } TopicDescription description = topicDescriptions.get(topicName); if (description != null) { - description.partitions().forEach(partitionInfo -> { - partitionsArray.add(createPartitionMetadata(partitionInfo)); - }); + description.partitions().forEach(partitionInfo -> partitionsArray.add(createPartitionMetadata(partitionInfo))); } root.set("partitions", partitionsArray); HttpUtils.sendResponse(routingContext, HttpResponseStatus.OK.code(), BridgeContentType.KAFKA_JSON, JsonUtils.jsonToBytes(root)); diff --git a/src/main/java/io/strimzi/kafka/bridge/http/HttpBridge.java b/src/main/java/io/strimzi/kafka/bridge/http/HttpBridge.java index 47fde470..9d7ea8b7 100644 --- a/src/main/java/io/strimzi/kafka/bridge/http/HttpBridge.java +++ b/src/main/java/io/strimzi/kafka/bridge/http/HttpBridge.java @@ -230,7 +230,7 @@ private CorsHandler getCorsHandler() { } @Override - public void stop(Promise stopPromise) throws Exception { + public void stop(Promise stopPromise) { log.info("Stopping HTTP-Kafka bridge verticle ..."); @@ -474,9 +474,7 @@ private void processProducer(RoutingContext routingContext) { source = new HttpSourceBridgeEndpoint<>(this.bridgeConfig, contentTypeToFormat(contentType), new ByteArraySerializer(), new ByteArraySerializer()); - source.closeHandler(s -> { - this.httpBridgeContext.getHttpSourceEndpoints().remove(httpServerRequest.connection()); - }); + source.closeHandler(s -> this.httpBridgeContext.getHttpSourceEndpoints().remove(httpServerRequest.connection())); source.open(); this.httpBridgeContext.getHttpSourceEndpoints().put(httpServerRequest.connection(), source); } @@ -613,9 +611,7 @@ private void errorHandler(RoutingContext routingContext) { } private void processConnection(HttpConnection httpConnection) { - httpConnection.closeHandler(close -> { - closeConnectionEndpoint(httpConnection); - }); + httpConnection.closeHandler(close -> closeConnectionEndpoint(httpConnection)); } /** diff --git a/src/main/java/io/strimzi/kafka/bridge/tracing/TracingConstants.java b/src/main/java/io/strimzi/kafka/bridge/tracing/TracingConstants.java index 2c36ea25..d24b40ff 100644 --- a/src/main/java/io/strimzi/kafka/bridge/tracing/TracingConstants.java +++ b/src/main/java/io/strimzi/kafka/bridge/tracing/TracingConstants.java @@ -22,8 +22,4 @@ public final class TracingConstants { public static final String OPENTELEMETRY_SERVICE_NAME_ENV_KEY = "OTEL_SERVICE_NAME"; /** OpenTelemetry service name system property */ public static final String OPENTELEMETRY_SERVICE_NAME_PROPERTY_KEY = "otel.service.name"; - /** OpenTelemetry traces exporter env var */ - public static final String OPENTELEMETRY_TRACES_EXPORTER_ENV_KEY = "OTEL_TRACES_EXPORTER"; - /** OpenTelemetry traces exporter system property */ - public static final String OPENTELEMETRY_TRACES_EXPORTER_PROPERTY_KEY = "otel.traces.exporter"; }