Skip to content
This repository has been archived by the owner on Oct 30, 2022. It is now read-only.

es5.6.4写入异常,日志没有报错,标准输出正常,ES中只有一条数据! #113

Open
ssdlyf opened this issue Feb 9, 2018 · 1 comment

Comments

@ssdlyf
Copy link

ssdlyf commented Feb 9, 2018

git clone 的是master分支,自己编译打包,Es 集群版本是5.6.4 ,日志没有看到报错
NewKafka 加consumer_settings session.timeout.ms 报错 2018-02-11 10:55:59,701 [main] ERROR com.ctrip.ops.sysdev.core.Main - java.lang.reflect.InvocationTargetException

@childe
Copy link
Owner

childe commented Mar 20, 2018

@ssdlyf 实在是抱歉, 我居然才刚刚看到这个issue .. :(
Kafka的Consumer Config需要key value都是string, 你是不是把session.timeout.ms 写成数字类型了?

Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
None yet
Projects
None yet
Development

No branches or pull requests

2 participants