В приведенном ниже коде я ожидал, что оператор print всегда будет печатать s=0 (поскольку это...

У меня есть задача реализовать две задачи, используя именованные каналы в C: Несколько...

У меня есть исходный веб-сервис, который выполняет операцию, которая не принимает тело в качестве...

Я новичок в Kakfa и учусь создавать и потреблять сообщения в и из темы Kafka. Я использую...

Я пытаюсь использовать Java для имитации набора счетчиков Checkout в торговом центре. Это...

У меня есть класс CAN-устройств низкого уровня, для которого я хотел бы создать событие...

В приведенном ниже коде я создаю producer thread и n consumer threads, которые читают с каждого из...

Мне нужно использовать записи из раздела Kafka в нескольких потоках с уникальными записями в каждом...

Я ищу существующую реализацию для параллельной очереди, которую можно использовать для реализации...

У меня проблема с производителем кафки.На самом деле я использую Spring Kafka, и отправка сообщений...

Данная программа представляет собой простую многопоточную программу.По какой-то причине, которую я...

Я недавно создал программу на python, которая очень выиграет от стратегии параллельных вычислений...

У меня есть проект Asp.Net 2.1, который выступает в качестве хоста службы для потребления сообщений...

У меня есть продюсер , который читает блоки текста с диска.Несколько потребителей выполняют...

1.- В этом назначении вы будете реализовывать свободный от тупиков вариант производителя /...

Я пытаюсь создать тайм-аут на уровне потребителя в Active MQ (версия 5.15.0).Предположим, что одно...

У меня есть три источника P1, P2, P3 и три потребителя с одной общей очередью.Производитель P1...

Код должен быть написан на C ++.Я упоминаю об этом на всякий случай, если кто-то предложит решение,...

У меня два производителя и один потребитель: public class Main { public static void main(String[]...

Всем привет,Я пытаюсь реализовать PACT JS.В настоящее время я имею в виду эту реализацию : npm...

Я ищу коллекцию типа BufferBlock но с такими методами, как: SendAsync<T>(T[]) T[]...

Я нашел пример, представляющий производителя-потребителя с двумя потоками. Но когда я посылаю...

Java EE 7 - Инъекция в объект Runnable / Callable Продолжая этот вопрос, у меня возникла ситуация .

Я пытался создать 2 темы для потребителя и 2 темы для производителя. Все 4 темы связаны с одним...

Как мы можем использовать пользовательские сообщения из нескольких или одного раздела в теме Kafka?...