Skip to content

Support for transactional consume-transform-produce loop #382

Open
@nick-zh

Description

@nick-zh

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.

Is related to #359

Metadata

Metadata

Assignees

No one assigned

    Labels

    Projects

    No projects

    Milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions