Исключение при подключении к Cassandra с CQL с использованием DataStax Java driver 1.0.4
У меня на ноутбуке работает Cassandra 1.2.11. Я могу подключиться к нему используяnodetool
а такжеcqlsh
но когда я пытаюсь использовать DataStax 1.0.4 Java API для соединения с помощью CQL 3.0, я получаю следующую ошибку:
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)
Я использую следующий код для подключения, взятый из документации DataStax. Я пробовал несколько номеров портов, в том числе оставляяwithPort()
взывать, но ничего не работает.
Cluster cluster = new Cluster.Builder()
.addContactPoints("localhost")
.withPort(9160)
.build();
С помощьюtelnet
Я могу убедиться, что сервер Cassandra определенно прослушивает каждый из указанных портов. Я также проверил, что все необходимые файлы jar библиотеки находятся на моем пути к классам, как описано в документации.