From 724bb582b505e83b16e00b050b3f826849916d10 Mon Sep 17 00:00:00 2001 From: Akram Yakubov Date: Sun, 24 Dec 2023 15:38:19 -0800 Subject: [PATCH] Fix static member (#655) --- .../stream/KafkaClientConnectionPool.java | 15 +++++++-------- 1 file changed, 7 insertions(+), 8 deletions(-) diff --git a/runtime/binding-kafka/src/main/java/io/aklivity/zilla/runtime/binding/kafka/internal/stream/KafkaClientConnectionPool.java b/runtime/binding-kafka/src/main/java/io/aklivity/zilla/runtime/binding/kafka/internal/stream/KafkaClientConnectionPool.java index 47440a09ce..89b5c15fbf 100644 --- a/runtime/binding-kafka/src/main/java/io/aklivity/zilla/runtime/binding/kafka/internal/stream/KafkaClientConnectionPool.java +++ b/runtime/binding-kafka/src/main/java/io/aklivity/zilla/runtime/binding/kafka/internal/stream/KafkaClientConnectionPool.java @@ -78,7 +78,6 @@ public final class KafkaClientConnectionPool extends KafkaClientSaslHandshaker private static final int SIGNAL_STREAM_WINDOW = 0x80000006; private static final int SIGNAL_CONNECTION_CLEANUP = 0x80000007; private static final int SIGNAL_NEXT_REQUEST = 0x80000008; - private static final StringBuilder CLUSTER = new StringBuilder(""); private final BeginFW beginRO = new BeginFW(); private final DataFW dataRO = new DataFW(); @@ -173,7 +172,7 @@ private MessageConsumer newStream( final ProxyBeginExFW proxyBeginEx = extension.get(proxyBeginExRO::tryWrap); MessageConsumer newStream = null; - CLUSTER.setLength(0); + final StringBuilder cluster = new StringBuilder(); if (proxyBeginEx != null) { @@ -181,21 +180,21 @@ private MessageConsumer newStream( String host = inet.destination().asString(); int port = inet.destinationPort(); - CLUSTER.append(host); - CLUSTER.append(":"); - CLUSTER.append(port); + cluster.append(host); + cluster.append(":"); + cluster.append(port); if (proxyBeginEx.infos() != null) { proxyBeginEx.infos().forEach(i -> { - CLUSTER.append(":"); - CLUSTER.append(i.authority().asString()); + cluster.append(":"); + cluster.append(i.authority().asString()); }); } } - final KafkaClientConnection connection = connectionPool.computeIfAbsent(CLUSTER.toString(), s -> + final KafkaClientConnection connection = connectionPool.computeIfAbsent(cluster.toString(), s -> newConnection(originId, routedId, authorization)); newStream = connection.newStream(msgTypeId, buffer, index, length, sender);