- Javadoc Update: fix a few missing params and exclude a few packages
- Add native support for Prometheus
- Rework cleanup process on shutdown
- Add secor.max.active.files property to controll active file count
- Add max.poll.interval.ms kafka producer setting
- Fix various unit test failures related to powermock running in JDK 11
- Upgrade guava to 24.1.1 to address the following security issue
- Upgrade parquet version from 1.9.0 to 1.11.0
- Change default build profile to kafka-2.0.0 to work with kafka client library 2.0.0 and above
- Add support to upload last seen offset onto ZK to solve the deterministic uploading
- Enhance secor's metrics monitoring library to integrate with more metrics backend
- ProgressMonitor: Handle failure of partition
- Add more metrics for uploader
- Support Micrometer metrics facade to integrate with more metrics libraries
- JSON array ob object saved as ORC format
- docker-entrypoint.sh shouldn't use Bash if syntax
- Handle missing topic list config
- Tighten up the curator API
- Message offset adjust
- Support union types
- Reject non-string keys
- Failed to apply upload policy
- Handle map types
- Test case for JsonORCFileReaderWriterFactory
- Query Avro schema from schema registry if it is missing
- Adding exec to the java command in the docker entrypoint
- Changing shell in docker-entrypoint.sh from bash to sh
- Added the ability to configure the topic-to-Avro-schema relationship manually (i.e. not using Confluent Schema Registry
- Using duration to match configuration parameter
- WIP avro field parser
- Fix messagePack, try-with-resources
- Send null messages to kafka avro deserializer
- Add deterministic upload mode
- Add message.timestamp.skew.max.ms to secor configuration
- Fix deadlock when secor.upload.on.shutdown=true