如何连接cassandra与logstash输入？-Java 学习之路

Logstash.conf

输入{tcp {port => 7199}}输出{elasticsearch {hosts => [“localhost”]}}

Cassandra在本地主机上运行的7199端口和jhipster应用程序上运行：8080 . 我们无法通过my_application添加到logstash中

找不到log4j2文件 .

enter image description here

1 回答

我想你可以使用JDBC插件：

https://github.com/logstash-plugins/logstash-input-jdbc

input {
   jdbc {
      jdbc_connection_string => "jdbc:cassandra://hostname:XXXX" # Your port
      jdbc_user => "user" # The user value
      jdbc_password => "password" # The password
      jdbc_driver_library => "$PATH/cassandra_driver.jar" # Jar path
      jdbc_driver_class => "org.apache.cassandra.cql.jdbc.CassandraDriver" # Driver
      statement => "SELECT * FROM keyspace.my_table" # Your query
   }
}

回复于 2024-05-04T15:41:26+08:00

如何连接cassandra与logstash输入？

1 回答

相关问题