我目前正在使用结构化流来消费来自 Kafka 的消息
该消息的原始格式具有以下模式结构
root
|-- incidentMessage: struct (nullable = true)
| |-- AssignedUnitEvent: array (nullable = true)
| | |-- element: struct (containsNull = true)
| | | |-- CallNumber: string (nullable = true)
| | | |-- Code: string (nullable = true)
| | | |-- EventDateTime: string (nullable = true)
| | | |-- EventDispatcherID: string (nullable = true)
| | | |-- ID: string (nullable = true)
| | | |-- Notes: string (nullable = true) …