using github kafka dependency
correct pattern match in BufferedFSM
make kafka producer buffered. partition ensembles by number of actual partitions in topic