priteshgudge opened a new pull request, #241: URL: https://github.com/apache/flink-connector-kafka/pull/241
When deserialization fails in `KafkaRecordEmitter`, the error message doesn't include which Kafka record caused the failure: ``` Failed to deserialize consumer record due to ``` In production environments with many topics and partitions, this makes root-cause analysis difficult. Engineers have to add custom logging and redeploy to locate the problematic record. This change adds topic, partition, and offset to the exception message: ``` Failed to deserialize consumer record from topic=my-topic, partition=117, offset=448550177 due to ``` JIRA: https://issues.apache.org/jira/browse/FLINK-39320 -- 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]
