diff --git a/src/SharpPulsar.Test/ZeroQueueSizeTest.cs b/src/SharpPulsar.Test/ZeroQueueSizeTest.cs
index 55360cfb..19b4f61f 100644
--- a/src/SharpPulsar.Test/ZeroQueueSizeTest.cs
+++ b/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());
                 }
diff --git a/src/SharpPulsar/Interfaces/ISchema.cs b/src/SharpPulsar/Interfaces/ISchema.cs
index 9ef200ff..e9951f3d 100644
--- a/src/SharpPulsar/Interfaces/ISchema.cs
+++ b/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);
 		}
diff --git a/src/SharpPulsar/PartitionedProducerActor.cs b/src/SharpPulsar/PartitionedProducerActor.cs
index c569f212..27eaf2a4 100644
--- a/src/SharpPulsar/PartitionedProducerActor.cs
+++ b/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;
diff --git a/src/SharpPulsar/TopicListWatcherActor.cs b/src/SharpPulsar/TopicListWatcherActor.cs
index 20e24122..fbc5f0a2 100644
--- a/src/SharpPulsar/TopicListWatcherActor.cs
+++ b/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;