代码拉取完成，页面将自动刷新
在调用项目中resources目录下创建log4j.properties
# 设置日志级别
log4j.rootLogger=debug,STDOUT
log4j.additivity.org.apache=true
log4j.appender.STDOUT=org.apache.log4j.ConsoleAppender
log4j.appender.STDOUT.layout=org.apache.log4j.PatternLayout
log4j.appender.STDOUT.layout.ConversionPattern=[%d{HH:mm:ss,SSS}][%5p] %c:%L - %m%n
调用方法 类：com.gitee.jastee.es.ElasticSearchSQL 方法：public static String query(String[] args)
代码调用：
String query = com.gitee.jastee.es.ElasticSearchSQL.query(args);
System.out.println(query);
传入参数 样例:
--es.address 10.16.0.33:9200 --es.sql "select * from ads_user_profile limit 1 " --es.security true --es.authorization "Basic ZWxhc3RpYzpBdnJpczJAMjIjIQ==" --format true
或
--es.address 10.16.0.33:9200 --es.sql "select * from ads_user_profile limit 1 " --es.security true --es.username elastic --es.password password123 --format true
参数说明：
| 参数 | 说明 | 默认值 | 样例 |
|---|---|---|---|
| --es.address | ES地址 | - | 10.16.0.33:9200 |
| --es.sql | 查询SQL | - | select * from ads_user_profile |
| --es.security | 是否启用认证 | false | true |
| --es.authorization | 认证配置 | - | Basic ZWxhc3RpYzpBdnJpczJAMjIjIQ== |
| --es.username | 认证用户(与es.authorization二选一) | - | elastic |
| --es.password | 认证密码(与es.authorization二选一) | - | elasticpassword |
| --format | 输出数据是否格式化打印 | false | true |
| 参数 | 说明 | 默认值 | 样例 |
|---|---|---|---|
| --kafka.topic | Kafka Topic | - | topicName |
| --kafka.bootstrap.servers | 连接Kafka地址 | 0.0.0.0:9092 | 10.8.10.10:9092 |
| --kafka.delete.partition | 需要删除的分区 | - | 0 |
| --kafka.delete.offset | 需要删除的Offset | - | 0 |
此处可能存在不合适展示的内容，页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容，可点击提交进行申诉，我们将尽快为您处理。