marmaray
marmaray copied to clipboard
Kafka to Hoodie support
- Add an example job that reads from Kafka and writes to Hoodie
- Add
KafkaSchemaServiceReaderabstract classes - Add
record_key,partition_pathandsink_opconfiguration support through the configuration file - Fix bug for edge case when the Job starts reading from Kafka's initial offset. The older code just exited without performing any tasks