public void bounce(int brokerId) {
        harness.killBroker(brokerId);
        boolean allBrokersDead = harness.aliveBrokers().isEmpty();
        harness.startBroker(brokerId);
        if (allBrokersDead) {
            reinitClients();
        }
        initContext();
    }
Send the given records trying to honor the batch size. This is attempted
with a large producer linger and the use of an explicit flush every time
the number of a "group" of records reaches the batch size.
@param recordsToProduce the records to produce
@param batchSize the batch size
storage/src/test/java/org/apache/kafka/tiered/storage/TieredStorageTestContext.java