refactoring of the kafka installation