Tengo Cassandra 1.2.11 corriendo en mi laptop. Puedo conectarme usandonodetool ycqlsh pero cuando intento usar la API Java DataStax 1.0.4 para conectarme utilizando CQL 3.0, aparece el siguiente error:

com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s) tried for query failed (tried: localhost/127.0.0.1 ([localhost/127.0.0.1] Unexpected error during transport initialization (com.datastax.driver.core.TransportException: [localhost/127.0.0.1] Channel has been closed)))
    at com.datastax.driver.core.ControlConnection.reconnectInternal(ControlConnection.java:186)

Estoy utilizando el siguiente código para conectar, tomado de la documentación de DataStax. He intentado varios números de puerto, incluso dejando elwithPort() llamar pero nada parece funcionar.

Cluster cluster = new Cluster.Builder()
        .addContactPoints("localhost")
        .withPort(9160)
        .build();

Utilizandotelnet Puedo verificar que el servidor de Cassandra está escuchando definitivamente en cada uno de los puertos que he especificado. También he verificado que todos los archivos jar de biblioteca necesarios están en mi classpath como se describe en la documentación.