kozy

Great library! Thanks, should save me tons of work :) I just can not figure out how to access the result of the mutation after a successful submit. Do I...

**Describe the bug** Using Flink, running ParquetAvroWriters.forSpecificRecord(classOf[MyGenericRecord]) results in silently never consuming from topic. I see no consumer group appearing for it. **To Reproduce** Create a project, separating out the...