Hey! Sorry, I don’t know if this is the correct category.
It has been suggested that a transactional producer performing topic partition send can wrap the streaming to a consumer that transforms and writes to a KTable:
producer.beginTransaction();
producer.send(record);
// in-txn-scope: post topic partition write streamed record
// in-txn-scope: streamed record transformed and written to ktable
producer.commitTransaction();
Is this true or false?
Thanks a bunch!