反射input插件 kafka10时,报错
- Dominant language
- HTML
- Stars
- 269
- Forks
- 121
- PR merge metrics
- No merged PRs in 30d
Description
在InputFactor.java中46行，导致类型转换失败，不知道大神遇到过没，怎么解决
jlogstash start error:com.dtstack.jlogstash.inputs.Kafka10 cannot be cast to com.dtstack.jlogstash.inputs.BaseInput
com.dtstack.jlogstash.factory.InputFactory.getInstance(46)
com.dtstack.jlogstash.factory.InputFactory.getBatchInstance(64)
com.dtstack.jlogstash.assembly.AssemblyPipeline.assemblyPipeline(103)
com.dtstack.jlogstash.JlogstashMain.main(51)
Contributor guide
No contributing guide indexed for this repository
Research direction
Start with InputFactory.java at lines 46 and 64, then trace the calls from AssemblyPipeline.assemblyPipeline at line 103 and JlogstashMain.main at line 51. Reproduce the Kafka10 startup failure and inspect why the reflected object cannot be cast to BaseInput; done means the pipeline starts without this ClassCastException.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- java, kafka
- Domain
- backend, stream-processing
- Issue type
- Bug
- Difficulty
- 3/5
- Estimated time
- 1-2 days
- Activity status
- Stale
- Clarity
- Needs clarification
- Newbie friendliness
- 30/100