I guess that we always have a transaction open, not just when we have something to commit.
It seems like one solution is to open a transaction only when we have data to process. Although this might complicate things. Alternatively, is there a way to periodically send a "keep alive" message to let the broker know we do still intend to use that transaction? It seems like either this or just abort/close the empty txn and re-open is better than a super-long expiration time. Otherwise, why is there even an expiration time? Is there any tradeoff between having one transaction open for a super long time, vs periodically closing empty transactions and starting new ones? [ Full content available at: https://github.com/apache/kafka/pull/5428 ] This message was relayed via gitbox.apache.org for [email protected]
