Кой и как определи приоритета на известията: беше ли това приоритет за влизане в Kafka или за обработка?