an SQL schema for SSB data:

note: this does not replace your flume log.offset, but creates a way to search for messages, which you then retrieve from the log.