Kaf

Latest version: v0.2.3

Safety actively analyzes 613682 Python packages for vulnerabilities to keep your Python projects secure.

Scan your dependencies

Page 1 of 3

0.2.3

Added

- User functions are forced to materialise all results before any messages are produced

Removed

(nothing removed)

0.2.2

Added

- Added topic and broker to INFO log when message produced

Removed

(Nothing)

0.2.0

Change log:

- Redrafted error handling
- Added on_failure back

0.1.8

Change log:

- Removed call to logging.BasicConfig

0.1.7

Change log:

- Process decorator now has two new parameters: accepts and returns
- accepts parameter is used to indicate how kaf should parse the message values before passing to the user function.
- If accepts='bytes' then the raw message is passed
- If accepts='json' then kaf will attempt to parse the output of json.loads
- returns parameter is used to indicate how kaf should handle the values returned from the user function
- If returns='bytes' then kaf will pass the value directly to Kafka
- If returns='json' then kaf will serialize the value using json.dumps(value).encode('utf-8')

0.1.6

V0.1.6, because releasing every day is for winners.

Change log:
- Don't retry fatal KafkaErrors

Page 1 of 3

© 2024 Safety CLI Cybersecurity Inc. All Rights Reserved.