Я ищу документацию о том, как написать очередь MP/MC, чтобы она не блокировалась или даже не ждала. Я использую .Net 4.0. Нашел много кода на C++, но я не очень хорошо разбираюсь в моделях памяти, поэтому велика вероятность, что при переносе на C# я...

Я хочу создать производителя/потребителя с программой-менеджером в Go. Например: у меня есть 5 producers, 5 consumers and manager . У производителей есть their own local arrays , они перебирают их и отправляют элементы менеджеру. У потребителей...

У меня есть контроллер с производителем. @Named @SessionScoped public class UserController{ private User user; //other methods @Produces @User public User produceUser() { return user; } } Если я ввожу...

Создание сообщений с помощью Kafka import java.util.Date; import java.util.Properties; import kafka.common.FailedToSendMessageException; import kafka.javaapi.producer.Producer; import kafka.producer.KeyedMessage; import...

Я пытаюсь создать простой пакет для производителя Kafka в версии 4.0.3 apache Karaf. Вот мой код Java Properties props = new Properties(); props.put("bootstrap.servers", "localhost:9092"); props.put("acks", "all"); props.put("retries", 0);...

Я использую Kafka 0.10.1.1 и пишу производителя тестов, но получаю ошибку в обратном вызове producer.send onCompletion : producer.send(record, new Callback() { @Override public void onCompletion(RecordMetadata metadata,...

Я установил программное обеспечение Kafka на EC2. Моя проблема связана с подключением к брокеру извне AWS. У меня все работает изнутри. Итак, я могу запустить брокера, и как производитель, так и потребитель будут работать (с одного сервера). У...

Я использую Spring-Kafka версии 1.2.1, и, когда сервер Kafka отключен / недоступен, на время блокируется асинхронная отправка вызовов. Вроде таймаут TCP. Код выглядит примерно так: ListenableFuture<SendResult<K, V>> future =...

У меня есть требование обновить нашу инфраструктуру производителя/потребителя. Текущая установка выглядит так: Набор из 3 очередей с разным приоритетом (низкий, средний, высокий). When one our customers generate a task (i.e Process an...

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

Я пытаюсь опубликовать сообщение в kafka с помощью Spring Boot. Я могу телнетить, пинговать кафку. Я получаю эту ошибку: org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for geofencemonitorrequests-0: 240036 ms has...

Производитель A пишет сообщение брокеру A (раздел 1), а производитель B записывает то же сообщение брокеру A (раздел 1). Что происходит с сообщением или брокером? Я предполагаю, поскольку есть то же сообщение, производитель B останавливает то же...

Я пытаюсь создать простой поисковый робот, используя trio и asks . Я использую питомник для одновременного запуска нескольких сканеров и канал памяти для ведения списка URL-адресов для посещения. Каждый поисковый робот получает клоны обоих...