Sunday 13 August 2023

FasfKafka library: how to commit messages in consumer manually when enable_autocommit=False?

I want to read messages from Kafka topic (wrapping my message processor with consumes decorator of fastkafka library).

But I want not just to auto-commit messages, but to commit them manually -- and only if the message processing was correct (when my extra function that was processing their internal data did not throw any exception).

How can it be done? How can I commit messages manually -- and only when I really want to commit them?



from FasfKafka library: how to commit messages in consumer manually when enable_autocommit=False?

No comments:

Post a Comment