Дан набор сообщений, каждое из которых имеет атрибут приоритета. Может ли потребитель пропускать или игнорировать сообщения, атрибут приоритета которых недостаточно высок?
Сначала я десериализовал сообщения, потребляемые потребителем kafka-python, проверил уровень приоритета и отбросил те сообщения, которые не соответствовали требуемому уровню приоритета.
Но я обеспокоен тем, что если сообщение большое, значительное время будет потрачено впустую на десериализацию сообщений, которые не будут обрабатываться дальше. Нет ли способа сделать это при чтении из очереди кафки?
