I tested this feature in local, and want to contribute to this project.
1. What needs to be done?
: Implement "ThriftMessageDecoder" for Thrift Stream Ingestion
2. Why the feature is needed (e.g. describing the use case).
: Here is example case
- I work on AI team and our services communicate based on thrift.
- We stack log data on kafka.
- I want to stream ingest thrift data through kafka, and add OLAP dashboards.
3. It may also include an initial idea/proposal on how as well.
- locate thrift-jar file to /lib folder
- using ThriftRecordExtractor & complexTypeConfig for decoding