zephyr45 commented on issue #13044: URL: https://github.com/apache/seatunnel/issues/13044#issuecomment-6500297286
Confirmed on the official 2.3.13 binary with its matching Kafka connector, Java 11 and `confluentinc/cp-kafka:7.0.9`. I used 100 distinct text records in a two-partition Kafka source (`max.poll.records=1`), a one-partition sink, `EXACTLY_ONCE`, and a common configured prefix for the parallel writers. With parallelism 1, all 100 expected records were visible to `read_committed`, with no fencing. With parallelism 2, the logs contained `ProducerFencedException`, but the job reported `FINISHED`, 100 read and 100 written, and the command exited 0. Only 50 distinct records were visible to `read_committed`. Each run had its own sink topic and prefix, so the two runs could not fence one another. -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
