commit 25a458e2b5c94cbf0a2c6cdeefdcbc75d09cd93d
author Kristian Andersen <kandersen82@users.noreply.github.com> Tue Mar 30 13:53:25 2021 +0200
committer GitHub <noreply@github.com> Tue Mar 30 13:53:25 2021 +0200
tree a5a6d21c2ddc2949c02c7ef3b0626ec8fb14a201
parent 6950c11c6190ad7e460c2b879224f64b43b480cf

Fixed issue with producing with schema to non existing topic (#70)

Thanks! :-)

src/DotPulsar/Internal/ProducerChannelFactory.cs

diff --git a/src/DotPulsar/Internal/ProducerChannelFactory.cs b/src/DotPulsar/Internal/ProducerChannelFactory.cs
index 7d9a1ac..57fd701 100644
--- a/src/DotPulsar/Internal/ProducerChannelFactory.cs
+++ b/src/DotPulsar/Internal/ProducerChannelFactory.cs
@@ -56,9 +56,9 @@
         public async Task<IProducerChannel> Create(CancellationToken cancellationToken)
         {
             var connection = await _connectionPool.FindConnectionForTopic(_commandProducer.Topic, cancellationToken).ConfigureAwait(false);
-            var schemaVersion = await GetSchemaVersion(connection, cancellationToken).ConfigureAwait(false);
             var channel = new Channel(_correlationId, _eventRegister, new AsyncQueue<MessagePackage>());
             var response = await connection.Send(_commandProducer, channel, cancellationToken).ConfigureAwait(false);
+            var schemaVersion = await GetSchemaVersion(connection, cancellationToken).ConfigureAwait(false);
             return new ProducerChannel(response.ProducerId, response.ProducerName, connection, _compressorFactory, schemaVersion);
         }