text: const requestV6 = require('../v6/request')
  
  /**
   * V7 indicates ZStandard capability (see KIP-110)
   * @see https://github.com/apache/kafka/blob/9c8f75c4b624084c954b4da69f092211a9ac4689/clients/src/main/java/org/apache/kafka/common/requests/ProduceRequest.java#L118-L121
   *
   * Produce Request (Version: 7) => transactional_id acks timeout [topic_data]
   *   transactional_id => NULLABLE_STRING
   *   acks => INT16
   *   timeout => INT32
   *   topic_data => topic [data]
   *     topic => STRING
   *     data => partition record_set
   *       partition => INT32
   *       record_set => RECORDS
   */
  
  module.exports = ({
    acks,
    timeout,
    transactionalId,
    producerId,
    producerEpoch,
    compression,
    topicData,
  }) =>
    Object.assign(
      requestV6({
        acks,
        timeout,
        transactionalId,
        producerId,
        producerEpoch,
        compression,
        topicData,
      }),
      { apiVersion: 7 }
    )
  