fixing the kafka topology