Нужен определенный файл JAR для logstash в Кассандре - PullRequest
Новая
       15

Нужен определенный файл JAR для logstash в Кассандре

0 голосов
/ 19 сентября 2019

Я не могу подключить Logstash к cassandra и прочитать данные с него.

Я протестировал Logstash с PostgreSQL и несколькими другими базами данных, используя следующий очень простой файл конфигурации. У меня нет пользователей в cassandraно файл не будет работать без добавления пользовательской строки 

input {
    jdbc {
        jdbc_connection_string =>"jdbc:cassandra://[IP]:9160/[KEYSPACENAME]"
        jdbc_user => "cassandra"
        jdbc_driver_library =>"/$PATH/cassandrajdbc1.2.jar"
        jdbc_driver_class => "com.dbschema.CassandraJdbcDriver"
        statement => "SELECT * FROM [KEYSPACE].[COLUMNFAMILY]"
         }
      }
output {
    stdout {
       codec => json_lines
           }
        }

Я прочитал несколько вопросов, касающихся создания одного файла JAR, и попробовал драйвер datastax, но он все еще не работает.Любые идеи, что может быть не так

ОШИБКА MSG: 

Plugin: <LogStash::Inputs::Jdbc jdbc_user=>"cassandra", statement=>"SELECT * FROM [KEYSPACE].[TABLE]", jdbc_driver_library=>"$PATH/Desktop/cassandrajdbc1.2.jar", jdbc_connection_string=>"jdbc:cassandra://[IP]:9160/[NAME]", id=>"a461c0d139d41966c9fc9987effdb83e5dd3b226fbc12dc308926cd00bc39b96", jdbc_driver_class=>"com.dbschema.CassandraJdbcDriver", enable_metric=>true, codec=><LogStash::Codecs::Plain id=>"plain_6172c800-05ec-4651-8b07-756c160e466f", enable_metric=>true, charset=>"UTF-8">, jdbc_paging_enabled=>false, jdbc_page_size=>100000, jdbc_validate_connection=>false, jdbc_validation_timeout=>3600, jdbc_pool_timeout=>5, sql_log_level=>"info", connection_retry_attempts=>1, connection_retry_attempts_wait_time=>0.5, parameters=>{"sql_last_value"=>2019-09-19 08:29:18 UTC}, last_run_metadata_path=>"$PATH/.logstash_jdbc_last_run", use_column_value=>false, tracking_column_type=>"numeric", clean_run=>false, record_last_run=>true, lowercase_column_names=>true>
  Error: com.dbschema.CassandraJdbcDriver not loaded. Are you sure you've included the correct jdbc driver in :jdbc_driver_library?
  Exception: LogStash::ConfigurationError
  Stack: $PATH/logstash-7.3.2/vendor/bundle/jruby/2.5.0/gems/logstash-input-jdbc-4.3.13/lib/logstash/plugin_mixins/jdbc/jdbc.rb:163:in `open_jdbc_connection'
$PATH/logstash-7.3.2/vendor/bundle/jruby/2.5.0/gems/logstash-input-jdbc-4.3.13/lib/logstash/plugin_mixins/jdbc/jdbc.rb:221:in `execute_statement'
$PATH/logstash-7.3.2/vendor/bundle/jruby/2.5.0/gems/logstash-input-jdbc-4.3.13/lib/logstash/inputs/jdbc.rb:277:in `execute_query'
$PATH/logstash-7.3.2/vendor/bundle/jruby/2.5.0/gems/logstash-input-jdbc-4.3.13/lib/logstash/inputs/jdbc.rb:263:in `run'
...