Может кто-нибудь, пожалуйста, подтвердите, прав я или нет в этом. Мне кажется, что операция "селектор" выполняется в реализации MessageConsumer. (т. е. ВСЕ сообщения по-прежнему отправляются от брокера сообщений к MessageConsumer, а затем над этими...

Я реализую потребителя OAuth, который будет работать на различных приставках. Некоторые из них не предоставляют никаких средств для постоянного хранения пользовательских данных. При выключении приставки все данные теряются (кроме прошивки, конечно)....

У нас есть два потребителя с привязкой c1 (в php) для обмена 1, очереди 1 и ключа маршрутизации 1; и c2 (в java) binging для обмена 1, очереди 1 и ключа маршрутизации 2. т.е. разные ключи маршрутизации, но обмен и очередь такие же. в php мы...

У меня проблемы с опросом сообщений от Kafka в группе потребителей. Мой потребительский объект назначается данному разделу с помощью self.ps = TopicPartition(topic, partition ) и после этого потребитель присваивает этому разделу:...

Я создал этот класс GenericBuilder (едва вдохновленный Как реализовать конструктор шаблон в Java 8? ) public class GenericBuilder<T> { private final T instance; private GenericBuilder(T instance) { this.instance =...