a rewrite of kafka in java