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.
For the use case where you have the following:
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_transactionfor which we should add support for.