Skip to content
Snippets Groups Projects
Commit 4d3cb983 authored by vlorentz's avatar vlorentz
Browse files

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], ...]
parent ce6cb80e
No related branches found
No related tags found
Hide whitespace changes
Inline Side-by-side
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment