def METHOD_NAME(producer: Producer, record_count: int):
    for idx in range(0, record_count):
        # Sleep for 1 second, so that the record-receipts can be received
        # for previosly produced records.
        time.sleep(1)
        producer.produce(ProduceRecord("key_" + str(idx), "value_" + str(idx)))