'Decode ProduceResponse to ProduceResponsePayload
Arguments:
response: ProduceResponse
Return: list of ProduceResponsePayload'

@classmethod
def decode_produce_response(cls, response):

    return [kafka.structs.ProduceResponsePayload(topic, partition, error, offset) for (topic, partitions) in response.topics for (partition, error, offset) in partitions]
