diff --git a/src/KafkaNET.Library/Consumers/PartitionLeaderFinder.cs b/src/KafkaNET.Library/Consumers/PartitionLeaderFinder.cs
index e0bc488..1d1b5be 100644
--- a/src/KafkaNET.Library/Consumers/PartitionLeaderFinder.cs
+++ b/src/KafkaNET.Library/Consumers/PartitionLeaderFinder.cs
@@ -36,6 +36,10 @@ internal class PartitionLeaderFinder
         private static readonly int FailureRetryDelayMs = (int)TimeSpan.FromSeconds(5).TotalMilliseconds;
 
         private const string clientId = "LeaderFetcher";
+        
+        private const short VersionId = 0;
+        
+        private const int CorrelationId = 0;
 
         private readonly Cluster _brokers;
 
@@ -77,7 +81,7 @@ public void Start()
                             var consumer = new Consumer(_config, broker.Value.Host, broker.Value.Port);
                             try
                             {
-                                IEnumerable<TopicMetadata> metaData = consumer.GetMetaData(TopicMetadataRequest.Create(new[] { partition.Topic }, 1, 0, clientId));
+                                IEnumerable<TopicMetadata> metaData = consumer.GetMetaData(TopicMetadataRequest.Create(new[] { partition.Topic }, VersionId, CorrelationId, clientId));
                                 if (metaData != null && metaData.Any())
                                 {
                                     PartitionMetadata newPartitionData = metaData.First().PartitionsMetadata.FirstOrDefault(p => p.PartitionId == partition.PartitionId);
@@ -120,4 +124,4 @@ public void Stop()
             _stop = true;
         }
     }
-}
\ No newline at end of file
+}