Warn the user of probable point of failure

[gurghet]

tamer/core/src/main/scala/tamer/Tamer.scala

Line 128 in a1a33f5

queue.offer((Right(TransactionDelimiter(p)), Chunk.empty)) *>

A nice enhancement would be to peek into the kafka producer config, get the transaction timeout and issue a human readable warning in case the transaction is still open, the kafka one is hard to understand and often at the other end of the system (wherever the broker is).
Something like "hey, your transaction timeout is set to 30s and yet we are, consider increasing the timeout."