Вы сохраняли все сообщения из Kafka в отдельную таблицу? Какой в этом был смысл, разве Kafka была недостаточна?