...
It may take longer than the transaction timeout for a task to flush all of its records to Kafka. In this case, there are some remedial actions that users can take to nurse their connector back to health: tune their producer configuration for higher throughput, increase the transaction timeout for the producers used by the connector, decrease the offset commit interval (if using interval-based transaction boundaries), or reconfigure it to produce records with a lower throughputswitch to the poll
value for the transaction.boundary
property. We will include include these steps in the error message for a task that fails due to producer transaction timeout.
...