Rust implementation of kafka
${LOG_DIR}\
logs\
${topic.name}\
${partition}\
${fmt %020d start_offset}.log{|.index|.cleaned}
broker\
raft\
...
config\
config.yaml