v1.4.3
- Provide a kafka metrics reporter implementation to collect kafka client metrics to own kafka cluster.
- Retry when connection exception in DirectLoghubInputDStream.
- Support do a batch computing on LogService.
- Add tag information into LogService RDD.