diff --git a/benchmarks/Compression/MessageBytes.cs b/benchmarks/Compression/MessageBytes.cs index 7124e5f97..11ee9a48e 100644 --- a/benchmarks/Compression/MessageBytes.cs +++ b/benchmarks/Compression/MessageBytes.cs @@ -28,7 +28,7 @@ static MessageBytes() SmallProtobufMessageBytes = new ReadOnlySequence(smallMessage.ToByteArray()); SmallJsonMessageBytes = new ReadOnlySequence(Encoding.UTF8.GetBytes(JsonFormatter.Default.Format(smallMessage))); - var largeMessage = CreateMessage(1024*1024); //1MB + var largeMessage = CreateMessage(1024 * 1024); //1MB LargeProtobufMessageBytes = new ReadOnlySequence(largeMessage.ToByteArray()); LargeJsonMessageBytes = new ReadOnlySequence(Encoding.UTF8.GetBytes(JsonFormatter.Default.Format(largeMessage))); } diff --git a/src/DotPulsar/Internal/ProducerChannelFactory.cs b/src/DotPulsar/Internal/ProducerChannelFactory.cs index ce75cf47c..70bef2c87 100644 --- a/src/DotPulsar/Internal/ProducerChannelFactory.cs +++ b/src/DotPulsar/Internal/ProducerChannelFactory.cs @@ -37,7 +37,7 @@ public ProducerChannelFactory( ProducerAccessMode producerAccessMode, SchemaInfo schemaInfo, ICompressorFactory? compressorFactory, - Dictionary? properties) + Dictionary? properties) { _correlationId = correlationId; _eventRegister = eventRegister; diff --git a/tests/DotPulsar.Tests/IntegrationFixture.cs b/tests/DotPulsar.Tests/IntegrationFixture.cs index 09f00102c..18c5eecfa 100644 --- a/tests/DotPulsar.Tests/IntegrationFixture.cs +++ b/tests/DotPulsar.Tests/IntegrationFixture.cs @@ -25,9 +25,6 @@ namespace DotPulsar.Tests; public class IntegrationFixture : IAsyncLifetime { - private const string AuthenticationPlugin = "org.apache.pulsar.client.impl.auth.AuthenticationToken"; - private const string SecretKeyPath = "/pulsar/secret.key"; - private const string UserName = "test-user"; private const int PulsarPort = 6650; private const int ToxiProxyControlPort = 8474; private const int ToxiProxyPort = 15124;