fix 1131 Get non-procesed kafka messages at start