1. Напишите свой партишинер, который будет отправлять данные на несуществующую партицию
2. Обработайте сложившуюся ситуацию
3. Перепишите код так, чтобы timestamp у всех записей был одинаков/у всех разный