Details
Description
When a sink connector is configured with a DLQ and its topic is the same (or matches) as the topic in which the connector reads, the broker and/or connector might be exhausted in case the record send to the topic is invalid.
Based on the broker/connect config, the connector might fail throwing a RecordTooLargeException previous to exhaust the broker/connector.
Attachments
Issue Links
- links to
Merged to `trunk`, and backported to `2.6` (for upcoming 2.6.0), `2.5` (for upcoming 2.5.1), and `2.4` (for future 2.4.2).