Change log: - Fixed bug with unreferenced local variable sha256_prod
0.1.4
Changes:
- Result class removed - User functions should now yield key, value - Kaf will automatically convert key and value to bytes - Kafka functions (consume, produce, commit) will retry forever until successful - Commit logic changed
0.1.3
Minor changes to the logging and error handling. Also added an examples folder.
0.1.2
First release of Kaf. - Format-agnostic: user needs to deserialise and serialise input/output - Two decorators: process and on_processed