# JDBC input plugin error for cassandra for Logstash

**URL:** <https://discuss.elastic.co/t/jdbc-input-plugin-error-for-cassandra-for-logstash/159562>\
**Category:** Logstash\
**Created:** [December 5, 2018, 2:57pm UTC](https://discuss.elastic.co/t/jdbc-input-plugin-error-for-cassandra-for-logstash/159562 "2018-12-05T14:57:51Z")\
**Posts on this page:** 2\
**Page:** 1

<div class="post-metadata">

**Author:** ![Nishad\_Nazar](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/nishad_nazar/32/38475_2.png) [@Nishad\_Nazar](https://discuss.elastic.co/u/Nishad_Nazar)\
**Post date:** [December 5, 2018, 2:57pm UTC](https://discuss.elastic.co/t/jdbc-input-plugin-error-for-cassandra-for-logstash/159562/1 "2018-12-05T14:57:51Z")

</div>

Hi,  
I have followed almost every link in this community and all over, still not able to get Cassandra data to logstash using jdbc input plugin.  
Intially i USed cassandra jdbc driver from Maven repository and driver class being '"org.apache.cassandra.cql.jdbc.CassandraDriver'

But now I'm using cassandra jdbc from dbschema and class driver is 'com.dbschema.CassandraJdbcDriver'

My logstash conf file is in conf.d and the file is:  
input {  
jdbc {  
# cassandra jdbc connection string to our database, thingsboard  
jdbc\_connection\_string =\> "jdbc:cassandra://localhost:9042/thingsboard"  
# The user we wish to execute our statement as  
jdbc\_user =\> ""  
jdbc\_password =\> ""  
# The path to our downloaded jdbc driver  
jdbc\_driver\_library =\> "/home/ubuntu\_admin/cassandra\_driver/cassandrajdbc1.1.jar"  
# The name of the driver class for Cassandra  
#jdbc\_driver\_class =\> "org.apache.cassandra.cql.jdbc.CassandraDriver"  
jdbc\_driver\_class =\> "com.dbschema.CassandraJdbcDriver"  
# our query  
statement =\> "SELECT \* from ts\_kv\_cf"

```
    clean_run => true

    jdbc_paging_enabled => "true"
    jdbc_page_size => "50000"
}

```

}

output {  
stdout {codec =\> json\_lines }  
elasticsearch {  
"hosts" =\> "localhost:9200"  
"index" =\> "logs"  
"document\_type" =\> "data"

```
}

```

}

THis is my error in log:  
Unable to connect to database. Tried 1 times {:error\_message=\>"Java::JavaLang::NoClassDefFoundError: com/da$  
A plugin had an unrecoverable error. Will restart this plugin.  
Pipeline\_id:main  
Plugin: \<LogStash::Inputs::Jdbc jdbc\_paging\_enabled=\>true, jdbc\_password=\>, statement=\>"SELECT \* from ts\_kv\_cf", jdbc\_page\_size=\>50000, clean\_run=\>true, jd$  
Error: Java::JavaLang::NoClassDefFoundError: com/datastax/driver/core/policies/RetryPolicy  
Exception: Sequel::DatabaseConnectionError  
Stack: com.dbschema.CassandraJdbcDriver.connect(com/dbschema/CassandraJdbcDriver.java:38)

---

<div class="post-metadata">

**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\
**Post date:** [January 2, 2019, 2:59pm UTC](https://discuss.elastic.co/t/jdbc-input-plugin-error-for-cassandra-for-logstash/159562/3 "2019-01-02T14:59:43Z")

</div>

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.