marmaray
marmaray copied to clipboard
Kafka to Hoodie support
- Add an example job that reads from Kafka and writes to Hoodie
- Add
KafkaSchemaServiceReader
abstract classes - Add
record_key
,partition_path
andsink_op
configuration 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