Use KafkaBolt
Create databases at the start