kafka4s
kafka4s copied to clipboard
Example of implementation of the full consumer/producer Transactional loop
I'm looking for an example of the implementation of a client that consumer(read_commited) and produce transactionally with kafka4s. By any chance, do you have any such example ?