栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

logstash错误记录:Ҳ޷ Active

logstash错误记录:Ҳ޷ Active

在学习 ElasticSearch想通过logstash把数据库数据同步到ElasticSearch中,安装好后发现运行报错如下:


解决方法:
1、打开注册表编辑器,修改chcp 65001为chcp 65001 > nul

2、修改配置文件jvm.options,添加下面两行配置

-Dsun.stdout.encoding=UTF-8 
 
-Dsun.stderr.encoding=UTF-8

3、修改logstash-sample.conf配置文件,格式一定要正确,可以用复制下面的配置格式

# Sample Logstash configuration for creating a simple
# Beats -> Logstash -> Elasticsearch pipeline.

input {
    stdin {
    }
    jdbc {
      # mysql数据库连接
      jdbc_connection_string => "jdbc:mysql://127.0.0.1:3306/guli?useUnicode=true&characterEncoding=utf8&serverTimezone=UTC"
      # mysqly用户名和密码
      jdbc_user => "root"
      jdbc_password => ""
      # 驱动配置 这里填写你自己的mysql-connector-java-8.0.13.jar路径
      jdbc_driver_library => "D:\elasticsearch\logstash-6.3.2\mysql-connector-java-5.1.7-bin.jar"
      # 驱动类名
      jdbc_driver_class => "com.mysql.jdbc.Driver"
      jdbc_paging_enabled => "true"
      #指定每页显示300000条
      jdbc_page_size => "300000"
      # 执行指定的sql文件
 
     #执行的sql语句
       statement => "select * FROM t_blog WHERe update_time > :sql_last_value AND update_time < NOW() ORDER BY update_time desc"
      # 设置监听 各字段含义 分 时 天 月  年 ,默认全部为*代表含义:每分钟都更新
      schedule => "* * * * *"
      # 索引类型
      #type => ""
    }
}
 
 
output {
 
    elasticsearch {
        #es服务器
        hosts => ["localhost:9200"]
        #ES索引名称
        index => "blog"
        #主键自增ID
        document_id => "%{id}"
    }
    
    #设置json格式
    stdout {
        codec => json_lines
    }
}


转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/706735.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号