fixes

src/SharpPulsar.Test/ZeroQueueSizeTest.cs

@@ -98,7 +98,7 @@ public async Task ZeroQueueSizeNormalConsumer()
                     receivedMessages.Add(1);
                     _output.WriteLine($"Consumer received : {receivedMessages.Count}, {r}");
                 }
-                catch
+                catch(Exception ex)
                 {
                     _output.WriteLine("Consumer received : " + ex.ToString());
                 }

src/SharpPulsar/Interfaces/ISchema.cs

@@ -237,7 +237,7 @@ static ISchema<O> Avro<O>(ISchemaDefinition<O> schemaDefinition)
 		/// </summary>
 		/// <param name="pojo"> the POJO class to be used to extract the JSON schema </param>
 		/// <returns> a Schema instance </returns>
-		static ISchema<T> Json(Type pojo)
+		static ISchema<T> Json<T>(Type pojo)
 		{
 			return DefaultImplementation.NewJsonSchema(ISchemaDefinition<T>.Builder().WithPojo(pojo).Build());
 		}
@@ -247,7 +247,7 @@ static ISchema<T> Json(Type pojo)
 		/// </summary>
 		/// <param name="schemaDefinition"> the definition of the schema </param>
 		/// <returns> a Schema instance </returns>
-		static ISchema<T> Json(ISchemaDefinition<T> schemaDefinition)
+		static ISchema<T> Json<T>(ISchemaDefinition<T> schemaDefinition)
 		{
 			return DefaultImplementation.NewJsonSchema(schemaDefinition);
 		}

src/SharpPulsar/PartitionedProducerActor.cs

@@ -444,7 +444,7 @@ public async ValueTask OnTopicsExtended(ICollection<string> topicsExtended)
                         throw new PulsarClientException.NotSupportedException("not support shrink topic partitions");
                     }
                 }
-                catch 
+                catch (Exception ex)
                 {
                     _outerInstance._log.Error($"[{_outerInstance.Topic}] Auto getting partitions failed { ex}");
                     throw;

src/SharpPulsar/TopicListWatcherActor.cs

@@ -23,6 +23,7 @@ internal class TopicListWatcherActor : ReceiveActor, IWithUnboundedStash
         private readonly IActorRef _connectionHandler;
         private readonly IActorRef _self;
         private IActorRef _cnx;
+        private readonly TimeSpan _lookupDeadline;
         private readonly Collection<Exception> _previousExceptions = new Collection<Exception>();
         private readonly string _name;
         private readonly string _topicsPattern;