[SPARK-47135] Implement error classes for Kafka data loss exceptions

• Type: Task
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 4.0.0
• Fix Version/s: 4.0.0
• Component/s: Structured Streaming
• Labels: pull-request-available
• Assignee: B. Micheal Okutubo
• Reporter: B. Micheal Okutubo
• Created: 22/Feb/24 19:04
• Updated: 29/Feb/24 00:28
• Resolved: 29/Feb/24 00:28

Description

In the kafka connector code, we have several code that throws the java IllegalStateException to report data loss, while reading from Kafka. We want to properly classify those exceptions using the new error framework. 

Issue Links

• links to: GitHub Pull Request #45221