Fix for handling new partitions in consumer #346

Author: Lanayx

src/Pulsar.Client/Internal/MultiTopicsConsumerImpl.fs

@@ -512,6 +512,7 @@ type internal MultiTopicsConsumerImpl<'T> (consumerConfig: ConsumerConfiguration
                                 let stream = getStream topic.CompleteTopicName consumer
                                 consumers.Add(topic.CompleteTopicName, (consumer :> IConsumer<'T>, stream))
                                 stream)
+                            |> Seq.cache
                         currentStream.AddGenerators(newStreams)
                         Log.Logger.LogDebug("{0} success create consumers for extended partitions. old: {1}, new: {2}",
                             prefix, oldConsumersCount, totalConsumersCount )

src/Pulsar.Client/Pulsar.Client.fsproj

@@ -7,17 +7,17 @@
     <Title>Pulsar.Client</Title>
     <RootNamespace>Pulsar.Client</RootNamespace>
     <AssemblyName>Pulsar.Client</AssemblyName>
-    <Version>3.13.3</Version>
+    <Version>3.13.4</Version>
     <Company>F# community</Company>
     <Description>.NET client library for Apache Pulsar</Description>
     <RepositoryUrl>https://github.com/fsprojects/pulsar-client-dotnet</RepositoryUrl>
-    <PackageReleaseNotes>Fix Reader HasMessageAvailable behavior after seeking by timestamp</PackageReleaseNotes>
+    <PackageReleaseNotes>Fix for handling new partitions in consumer</PackageReleaseNotes>
     <PackageLicenseExpression>MIT</PackageLicenseExpression>
     <PackageProjectUrl>https://github.com/fsprojects/pulsar-client-dotnet</PackageProjectUrl>
     <RepositoryType>git</RepositoryType>
     <PackageTags>Apache;Pulsar;F#;FSharp</PackageTags>
     <Authors>Vladimir Shchur and contributors</Authors>
-    <PackageVersion>3.13.3</PackageVersion>
+    <PackageVersion>3.13.4</PackageVersion>
     <DebugType>portable</DebugType>
     <GenerateDocumentationFile>true</GenerateDocumentationFile>
     <PackageReadmeFile>README.md</PackageReadmeFile>