ResourceLeakDetector in r2dbc-sqlserver

[patriknw]

Shadow issue of r2dbc/r2dbc-mssql#279, which we have seen when running EventsBySlicePerfSpec and R2dbcJournalPerfSpec.

2024-02-02 07:20:24,357] [ERROR] [io.netty.util.ResourceLeakDetector] [] [] [JournalSpec-akka.actor.default-dispatcher-7] - LEAK: ByteBuf.release() was not called before it's garbage-collected. See https://netty.io/wiki/reference-counted-objects.html for more information.
Recent access records:
Created at:
	io.netty.buffer.PooledByteBufAllocator.newDirectBuffer(PooledByteBufAllocator.java:404)
	io.netty.buffer.AbstractByteBufAllocator.directBuffer(AbstractByteBufAllocator.java:188)
	io.netty.buffer.AbstractByteBufAllocator.directBuffer(AbstractByteBufAllocator.java:179)
	io.netty.buffer.AbstractByteBufAllocator.buffer(AbstractByteBufAllocator.java:116)
	io.r2dbc.mssql.codec.RpcEncoding.prepareBuffer(RpcEncoding.java:258)
	io.r2dbc.mssql.codec.RpcEncoding.lambda$encodeNull$2(RpcEncoding.java:181)
	io.r2dbc.mssql.codec.Encoded.getValue(Encoded.java:56)
	io.r2dbc.mssql.codec.ByteArray.fromEncoded(ByteArray.java:46)
	io.r2dbc.mssql.codec.ByteCodec.<clinit>(ByteCodec.java:41)
	io.r2dbc.mssql.codec.DefaultCodecs.<init>(DefaultCodecs.java:51)
	io.r2dbc.mssql.MssqlConnectionConfiguration.toConnectionOptions(MssqlConnectionConfiguration.java:197)
	io.r2dbc.mssql.MssqlConnectionFactory.<init>(MssqlConnectionFactory.java:64)
	io.r2dbc.mssql.MssqlConnectionFactory.<init>(MssqlConnectionFactory.java:56)
	io.r2dbc.mssql.MssqlConnectionFactoryProvider.create(MssqlConnectionFactoryProvider.java:206)
	io.r2dbc.mssql.MssqlConnectionFactoryProvider.create(MssqlConnectionFactoryProvider.java:48)
	io.r2dbc.spi.ConnectionFactories.find(ConnectionFactories.java:110)
	io.r2dbc.spi.ConnectionFactories.get(ConnectionFactories.java:140)
	akka.persistence.r2dbc.internal.sqlserver.SqlServerDialect$.createConnectionFactory(SqlServerDialect.scala:82)
	akka.persistence.r2dbc.ConnectionFactoryProvider.$anonfun$connectionFactoryFor$1(ConnectionFactoryProvider.scala:54)
	java.base/java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1708)
	akka.persistence.r2dbc.ConnectionFactoryProvider.connectionFactoryFor(ConnectionFactoryProvider.scala:52)
	akka.persistence.r2dbc.TestDbLifecycle.r2dbcExecutor(TestDbLifecycle.scala:33)
	akka.persistence.r2dbc.TestDbLifecycle.r2dbcExecutor$(TestDbLifecycle.scala:30)
	akka.persistence.r2dbc.journal.R2dbcJournalPerfSpec.r2dbcExecutor$lzycompute(R2dbcJournalPerfSpec.scala:19)
	akka.persistence.r2dbc.journal.R2dbcJournalPerfSpec.r2dbcExecutor(R2dbcJournalPerfSpec.scala:19)
	akka.persistence.r2dbc.TestDbLifecycle.beforeAll(TestDbLifecycle.scala:46)
	akka.persistence.r2dbc.TestDbLifecycle.beforeAll$(TestDbLifecycle.scala:43)
	akka.persistence.r2dbc.journal.R2dbcJournalPerfSpec.beforeAll(R2dbcJournalPerfSpec.scala:19)
	org.scalatest.BeforeAndAfterAll.liftedTree1$1(BeforeAndAfterAll.scala:212)
	org.scalatest.BeforeAndAfterAll.run(BeforeAndAfterAll.scala:210)
	org.scalatest.BeforeAndAfterAll.run$(BeforeAndAfterAll.scala:208)
	akka.persistence.PluginSpec.run(PluginSpec.scala:20)
	org.scalatest.tools.Framework.org$scalatest$tools$Framework$$runSuite(Framework.scala:321)
	org.scalatest.tools.Framework$ScalaTestTask.execute(Framework.scala:517)
	sbt.ForkMain$Run.lambda$runTest$1(ForkMain.java:414)
	java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
	java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
	java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
	java.base/java.lang.Thread.run(Thread.java:840)