Я строю систему, в которой несколько ботов производят сообщения, которые необходимо отправлять в Кафку. Тем не менее, некоторые боты генерируют гораздо больше сообщений, чем другие, и я хочу обеспечить справедливость, поэтому ни один бот не может затопить трубопровод Kafka и голодать. Bot to ActiveBotids. /> Это обеспечивает справедливость (1 сообщение на бот за цикл), избегает голода и поддерживает простые операции Redis.
Есть ли лучший способ сделать это?
Подробнее здесь: https://stackoverflow.com/questions/796 ... s-to-kafka
