Fetch supported produce version from apiVersions.

Author: OmniaGM

Diff for: clients/src/main/java/org/apache/kafka/clients/ApiVersions.java

@@ -74,7 +74,7 @@ private byte computeMaxUsableProduceMagic() {
     public synchronized byte maxUsableProduceMagic() {
         return maxUsableProduceMagic;
     }
-    public synchronized short getMaxSupportedProduceVersion() {
+    public synchronized short maxSupportedProduceVersion() {
         return maxProduceSupportedVersion;
     }
 

Diff for: clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java

@@ -27,7 +27,6 @@
 import org.apache.kafka.clients.Metadata;
 import org.apache.kafka.clients.MetadataSnapshot;
 import org.apache.kafka.clients.NetworkClientUtils;
-import org.apache.kafka.clients.NodeApiVersions;
 import org.apache.kafka.clients.RequestCompletionHandler;
 import org.apache.kafka.common.InvalidRecordException;
 import org.apache.kafka.common.KafkaException;
@@ -51,7 +50,6 @@
 import org.apache.kafka.common.metrics.stats.Avg;
 import org.apache.kafka.common.metrics.stats.Max;
 import org.apache.kafka.common.metrics.stats.Meter;
-import org.apache.kafka.common.protocol.ApiKeys;
 import org.apache.kafka.common.protocol.Errors;
 import org.apache.kafka.common.record.MemoryRecords;
 import org.apache.kafka.common.record.RecordBatch;
@@ -884,7 +882,7 @@ private void sendProduceRequest(long now, int destination, short acks, int timeo
                 minUsedMagic = batch.magic();
         }
         Map<String, Uuid> topicIds = getTopicIdsFromBatches(batches);
-        boolean canUseTopicId = apiVersions.getMaxSupportedProduceVersion() >= 12;
+        boolean canUseTopicId = apiVersions.maxSupportedProduceVersion() >= 12;
 
         ProduceRequestData.TopicProduceDataCollection tpd = new ProduceRequestData.TopicProduceDataCollection();
         for (ProducerBatch batch : batches) {