Вопросы по теме 'consumer'
Мой потребитель продукции зависает
Скопируйте приведенную ниже программу и попробуйте запустить ее в своей среде IDE. Это простая реализация Produce Consumer - она работает нормально, когда я использую один поток Producer и один Consumer, но терпит неудачу при использовании 2...
1163 просмотров
schedule
11.01.2023
Как реализовать безопасное использование OAuth2 в Javascript?
Я занимаюсь разработкой API на PHP, который будет использовать OAuth2.0. Моя конечная цель — создать внешнее приложение на javascript (используя AngularJS), которое напрямую обращается к этому API. Я знаю, что традиционно нет способа защитить...
39414 просмотров
schedule
05.07.2023
DeadLock в производителе-потребителе
I have following classes :
package com.akshu.multithreading;
public class ThreadResource {
static int a;
static boolean Value =false;
public synchronized int getA() {
while(Value == false){...
887 просмотров
schedule
28.02.2022
Библиотека PHP OAuth 1.0, которая обрабатывает пару ключ/секрет API и конечные точки (запрос, авторизация и доступ)
Я работаю с API OAuth 1.0, который требует использования API KEY/PAIR. Кроме того, он дает мне 3 URL-адреса:
Конечная точка токена запроса: /oauth/request_token
Конечная точка авторизации: /oauth/authorize
Конечная точка токена доступа:...
5202 просмотров
schedule
20.05.2022
Производитель-потребитель, использующий потоки
Я пишу программу, реализующую проблему производителя-потребителя на Java с использованием концепции многопоточности. Ниже несколько деталей, как я должен это сделать:
1) Основной поток должен создать буфер с емкостью, указанной в качестве...
10078 просмотров
schedule
28.09.2022
Проблема выбора потребителя в activeMQ
Сценарий: я отправляю пятьдесят тысяч сообщений в очередь с именем JUST.CN. И установка одного сообщения propertyString "myfilter = 'abc'" каждые 1000 сообщений. Теперь я создаю потребителя с тем же селектором для потребления сообщений. Однако...
7148 просмотров
schedule
01.04.2023
Как перестать потреблять сообщение из выборочной очереди — RabbitMQ
QueueingConsumer consumer = new QueueingConsumer(channel);
System.out.println(consumer.getConsumerTag());
channel.basicConsume("queue1", consumer);
channel.basicConsume("queue3", consumer);
Можно ли динамически прекратить потребление сообщений...
21234 просмотров
schedule
29.11.2022
SOAP потребителя веб-службы mule esb - ошибка: не указан префикс
Я пытаюсь воспроизвести поток «listInventory» из примера проекта «tshirt-service-consumer» среды выполнения сообщества Mule ESB 3.5.0 с моей собственной веб-службой SOAP. Но когда я запускаю проект, у меня в консоли появляется ошибка
WARN...
1652 просмотров
schedule
02.04.2022
Производитель-Потребитель в C++11
Я начал изучать манипулирование потоками и начал с простой программы, предназначенной для генерации случайных заглавных букв. Буквы генерируются случайным образом и добавляются в массив символов через производителя, и любые добавленные буквы...
1636 просмотров
schedule
04.03.2023
Потребительский блок java blockingqueue в полной очереди
Я пишу небольшую программу для помещения твитов из общедоступного потока Twitter в базу данных HBase. Программа использует два потока: один для сбора твитов, а другой для их обработки. Первый поток использует twitter4j StatusListener для получения...
726 просмотров
schedule
04.08.2022
Rabbitmq - новый потребитель ничего не получает
Я использую rabbitMQ для отправки задач рабочим (потребителям), которые создаются на ходу. В настоящее время каждый раз, когда создается новая задача, создается новый исполнитель. Проблема такая: -Пользователь создает задачу.
-Создан воркер,...
5047 просмотров
schedule
29.05.2023
Как отправить полезную нагрузку json при использовании API отдыха
У меня есть разработанное API, и я хочу использовать этот API в потоке мулов. Но когда я тестирую из chrome:postman, я получаю следующую ошибку.
Message payload is of type: BufferInputStream
Итак, я попытался зарегистрировать сообщение, и...
803 просмотров
schedule
08.06.2022
Что может привести к вызову задачи uvm Consumer «put» до того, как производитель выполнит myport.put
Мой uvm_driver (производитель) обменивается данными с uvm_component (потребителем) через порт put. Общий элемент представляет собой класс xfer_data uvm_transaction с двумя элементами данных и методом getdata. Драйвер вызывает getdata, затем...
77 просмотров
schedule
16.07.2022
Несколько производителей один потребитель
У меня проблемы с пониманием проблемы нескольких производителей и одного потребителя. Я работаю над заданием, и я не уверен, как работает создание двух производителей. Я понимаю, как работает проблема с одним производителем/потребителем, но я не могу...
804 просмотров
schedule
27.04.2023
Кафка: Как удалить данные, которые уже были потреблены потребителем?
Я установил server.properties '
log.retention.minutes = 8
очищать данные под кафка-журналами / каждые 8 минут автоматически,
Возможно ли, чтобы уборщик очищал только те данные, которые были потреблены, а данные, которые не потреблялись...
284 просмотров
schedule
08.03.2022
Распространение Kafka Consumer не работает должным образом
У меня есть три темы, каждая из которых имеет три раздела на кластере кафки.
теперь всего 9 разделов. и когда я создаю 9 потребителей... 6 простаивают. используются только три потребителя.
ожидание таково: каждый потребитель должен получить...
222 просмотров
schedule
17.03.2023
Kafka не получает сообщения при указании group_id в Python
Я использую Kafka ( kafka-python ) версии 3.0.0-1.3.0.0.p0.40. Мне нужно настроить потребителя для темы «моделирование» в Python. Когда я не указываю group_id, то есть group_id = None, он получает сообщения нормально. Однако, если я укажу group_id,...
2477 просмотров
schedule
15.02.2023
Возврат значения метода внутри выражения Consumer
Я пытаюсь вернуть логическое значение внутри метода и использую потребительскую функцию. Есть ли способ вернуть это значение непосредственно внутри этого выражения Consumer?
Вот код:
private static boolean uuidExists(UUID uuid) {...
1360 просмотров
schedule
09.07.2022
Почему при использовании Spring Cloud Contracts производитель создает контракты?
Я играл с Spring Cloud Contracts. Вот мое понимание рабочего процесса на данный момент.
На стороне сервера
Напишите договор (на Groovy или на ямле)
Автоматически генерировать тесты (с использованием плагина gradle)
Setup BaseClass,...
370 просмотров
schedule
12.05.2022
Как разработать API для получения клиентских событий от Kafka?
Я думаю о архитектурном паттерне, когда у каждого клиента моего сервиса есть свой потребитель кафки.
Например, есть тема events с некоторым коэффициентом репликации и некоторым количеством разделов, которые я использовал для масштабируемости....
74 просмотров
schedule
30.03.2023
