Support for transactional consume-transform-produce loop
nick-zh opened this issue · 0 comments
nick-zh commented
For the use case where you have the following:
- consumer reading messages
- processing those messages
- producing a result of those processed messages
- all the above being part of a transaction
We need to be able for the consumer offsets to be part of the transaction, this can be achieved by using rd_kafka_send_offsets_to_transaction for which we should add support for.