0.6.2
Core
- improved supervision strategy in the controller - high level exceptions resume, low-level restart and throwables escalate
- fixed gateway shutdown sequence during failure
Kafka
- configuring AdminClient in KafkaLogStorage with security settings inherited from kafka consumer
Spark
- LogRDD.json and .xml support for raw data
- LogRDD supports topics with null keys (and throws exception if null key is found in a compacted topic)
CLI
- added timelog utility for visualising time-compaction status of a kafka topic and time/offset ranges
Testing
- fixed flaky failover spec