Fix deserialization of extra_headers.
kafka_to_value didn't recursively convert to tuples, so they were
of type Tuple[List[bytes], ...] instead of Tuple[Tuple[bytes, bytes], ...]
Fix deserialization of extra_headers. Tags None Subscribers None
Description
Details
|