Yeah, I came to that conclusion later in working on the kafka ingestion piece. It's in part 3 -- https://github.com/fourk/blueflood/pull/3/files#diff-5a4eccd7c1fa3b97391c76db9b0297a1R22