Send hangs when using CompressionType.ZStd

[danielcrabtree]

If I create a producer using CompressionType.ZStd, then SendAsync hangs. If I create using CompressionType.LZ4, then it works as expected.

I'm using Pulsar.Client version 3.6.2.

[Lanayx]

This case is covered by integration tests, can you please check if they work for you?

https://github.com/fsprojects/pulsar-client-dotnet/blob/develop/tests/IntegrationTests/Compression.fs

[danielcrabtree]

I've run the integration tests and both of the compression tests passed.

Here is a MRE:

using Pulsar.Client.Api;
using Pulsar.Client.Common;

var client = await new PulsarClientBuilder()
    .ServiceUrl("pulsar://localhost:6650")
    .BuildAsync();

Console.WriteLine("Created Client");

var producer = await client.NewProducer()
    .Topic($"messages-{Guid.NewGuid().ToString()}")
    .ProducerName("test-compression")
    .CompressionType(CompressionType.ZStd)
    .CreateAsync();

Console.WriteLine("Created Producer");

await producer.SendAsync(new byte[] { 10, 10, 10 });

Console.WriteLine("Message Sent");

When I run this, it never gets to "Message Sent". However, it works as expected with CompressionType.LZ4.

[Lanayx]

@danielcrabtree I've just looked at the tests and found that found that they were incorrect - tasks were not awaited. I've corrected the tests and they still pass. You might want enable debug logs and analyze why you see that behavior. Notice, that you are using batched mode for producer, you can try non-batched (although tests work with both modes)
UPDATE: Also, note that tests are run at pulsar:2.11.4, if you are running a more modern version of pulsar, that can be the source of the issue