It seems that in case of broker restart a connector task may fail due to exceptions from transaction commit. I would expect the connector to retry and recover.
Attaching the exception log with stacktrace (sorry it got reordered).
iceberg_logs.txt
org.apache.kafka.common.KafkaException: Unexpected error in AddOffsetsToTxnResponse: The server experienced an unexpected error when processing the request.
It seems that in case of broker restart a connector task may fail due to exceptions from transaction commit. I would expect the connector to retry and recover. Attaching the exception log with stacktrace (sorry it got reordered). iceberg_logs.txt