AlertsTest.java

public class AlertsTest {

    @Test
    public void createAlerts() throws Exception {
        initSession();
        PreparedStatement createAlert = session.prepare(
                "INSERT INTO alerts (tenantId, alertId, payload) VALUES (?, ?, ?)");
        String tenantId = "alerts-tenant";
        int numAlerts = 100000000;
        CountDownLatch latch = new CountDownLatch(numAlerts);
        final Thread mainThread = Thread.currentThread();
        for (int i = 0; i < numAlerts; ++i) {
            String alertId = "alert-" + i;
            String payload = "payload-" + i;
            ResultSetFuture future = session.executeAsync(createAlert.bind(tenantId, alertId, payload));
            Futures.addCallback(future, new FutureCallback<ResultSet>() {
                @Override
                public void onSuccess(ResultSet result) {
                    latch.countDown();
                }

                @Override
                public void onFailure(Throwable t) {
                    mainThread.interrupt();
                }
            });
        }
        latch.await();
    }

}