From ec34c27af9eab3dd96a0310d3174c5aed87b5953 Mon Sep 17 00:00:00 2001 From: aakarshit Date: Fri, 28 Sep 2018 13:38:26 -0700 Subject: [PATCH] Changed versionId from 1 to 0, replaced hard coded values with constant fields --- src/KafkaNET.Library/Consumers/PartitionLeaderFinder.cs | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) 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 metaData = consumer.GetMetaData(TopicMetadataRequest.Create(new[] { partition.Topic }, 1, 0, clientId)); + IEnumerable 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 +}