fn make_counts_decoder() -> impl AvroDecode<Out = Vec<(Timestamp, usize)>>