Update initial pool size for topics

iggy-rs · Oct 9, 2024 · e539694 · e539694
1 parent 55a787a
commit e539694
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 5 deletions.
diff --git a/src/main/java/rs/iggy/clients/blocking/tcp/TopicsTcpClient.java b/src/main/java/rs/iggy/clients/blocking/tcp/TopicsTcpClient.java
@@ -52,7 +52,7 @@ public List<Topic> getTopics(StreamId streamId) {
     @Override
     public TopicDetails createTopic(StreamId streamId, Optional<Long> topicId, Long partitionsCount, CompressionAlgorithm compressionAlgorithm, BigInteger messageExpiry, BigInteger maxTopicSize, Optional<Short> replicationFactor, String name) {
         var streamIdBytes = toBytes(streamId);
-        var payload = Unpooled.buffer(23 + streamIdBytes.capacity() + name.length());
+        var payload = Unpooled.buffer(27 + streamIdBytes.readableBytes() + name.length());
 
         payload.writeBytes(streamIdBytes);
         payload.writeIntLE(topicId.orElse(0L).intValue());

diff --git a/src/main/java/rs/iggy/clients/blocking/tcp/UsersTcpClient.java b/src/main/java/rs/iggy/clients/blocking/tcp/UsersTcpClient.java
@@ -6,6 +6,7 @@
 import rs.iggy.user.*;
 import java.util.List;
 import java.util.Optional;
+import static rs.iggy.clients.blocking.tcp.BytesSerializer.nameToBytes;
 
 class UsersTcpClient implements UsersClient {
 
@@ -58,10 +59,8 @@ public IdentityInfo login(String username, String password) {
         var payloadSize = 2 + username.length() + password.length() + 4 + version.length() + 4 + context.length();
         var payload = Unpooled.buffer(payloadSize);
 
-        payload.writeByte(username.length());
-        payload.writeBytes(username.getBytes());
-        payload.writeByte(password.length());
-        payload.writeBytes(password.getBytes());
+        payload.writeBytes(nameToBytes(username));
+        payload.writeBytes(nameToBytes(password));
         payload.writeIntLE(version.length());
         payload.writeBytes(version.getBytes());
         payload.writeIntLE(context.length());