AHeise commented on PR #159: URL: https://github.com/apache/flink-connector-kafka/pull/159#issuecomment-2766182373
> Can you add some more decription to the commit message in which scenarios we can get a failed transaction? > > I would have expected many of the cases anyway restart the job due to risk of data loss. The short answer is in all cases with a known error where we don't fall over. See the committer. At this point, I'm not sure if all of these cases actually make sense or if a fall-over is better but I'd leave that for the future. At this point, we just know that there are cases that cause producers to be in invalid state after an error. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
