Описание тега producer
Продюсер - участник сценария "Продюсер-потребитель".
1
ответ
Почему *randNum увеличивается?
Пожалуйста, не отрицайте этот вопрос, я понимаю, что он не слишком конкретен, но это именно моя проблема. Я знаю, что делает каждая команда в моем коде, я просто не знаю, почему они там находятся. Это безумно сложно найти ответы, потому что мои вопр…
29 июл '13 в 12:50
1
ответ
Производитель.send не принимает тип KeyedMessage
Я пытался запустить этот код, но он не работает, так как производитель.send() не принимает тип KeyedMessage. Я попытался импортировать kafka.javaapi.producer.Producer вместо kafka.producer.Producer; но все еще не работает Код является: package sourc…
25 июл '16 в 22:27
0
ответов
rabbitmq-c amqp_confirm_select функция, как использовать ее для подтверждения производителя
rabbitmq-c имеет только amqp_confirm_select для подтверждения производителя, как его использовать? Я не могу найти способы использовать эту функцию, она используется в библиотеке rabbitmq-c? /** * amqp_confirm_select * * @param [in] state connection…
28 сен '18 в 12:59
3
ответа
Очередь без блокировки (или даже без ожидания) с несколькими потребителями
Я ищу документацию о том, как написать очередь MP/MC без блокировки или даже без ожидания. Я использую.Net 4.0. Нашел много кода на C++, но я не очень знаком с моделями памяти, поэтому есть большая вероятность, что я буду вносить некоторые ошибки пр…
20 май '11 в 22:45
1
ответ
Flume за подключение отказался от кафки брокера
Я пытаюсь отправить сообщения из Apache Flume в мой экземпляр Apache Kafka. Делая все это локально через localhost, у меня нет проблем. Когда я пытаюсь сделать это с разных виртуальных машин на моем компьютере, я получаю отказ в соединении в журнале…
26 фев '18 в 19:30
0
ответов
Поток Java, потребитель не хочет заканчивать
Почему мой поток (Runnable) не выходит из метода run(), как только он достигает конца блока? Это код: //1 Entry point for thread with run method public void run() { System.out.println("Hashmaker():/run(). " + threadName + " Running " ); try { String…
08 апр '16 в 07:30
1
ответ
Производитель-Потребитель в C++11
Я начал изучать работу с потоками и начал с простой программы, предназначенной для генерирования случайных заглавных букв. Буквы генерируются случайным образом и добавляются в массив символов через производителя, а все добавленные значения выводятся…
17 сен '15 в 18:24
0
ответов
Продюсер Потребительские Многопоточные проблемы печати
Я написал программу, которая имитирует проблему потребителя производителя, и столкнулся с несколькими проблемами. Это было написано с использованием Win32 API. Я использую два семафора, полный и пустой, чтобы выполнить подсчет для буфера, в котором …
12 апр '14 в 16:36
2
ответа
Генерация UUID в ответ на сообщение, отправленное Kafka Producer
Я пытаюсь разработать приложение, которое считывает байтовые массивы (представляющие структуру C и каждый массив, связанный с UUID) из кэша и отправляет его на Kafka Server через приложение Producer в C. Приложение производителя kafka накапливает фи…
06 июн '18 в 10:55
3
ответа
Исключение производителя Кафки NoClassDefFoundError
У меня есть какая-то проблема с Кафкой-продюсером, но я не знаю, как ее решить. Моя зависимость от Maven: <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka_2.10</artifactId> <version>0.10.1.1</…
20 июн '17 в 14:57
1
ответ
Как решить проблему "1 производитель 2 потребителя" в Java
Я довольно новичок в написании Java и сейчас пытаюсь реализовать другой аспект классической проблемы "производитель-потребитель". Я по-прежнему использую один источник, как обычно, который записывает строки в буфер. Этот буфер используется совместно…
13 дек '18 в 13:09
1
ответ
Как обработать файл ровно один раз
Мое Java-приложение считывает данные из каталога и помещает их в общую очередь общих ресурсов. Потребитель будет использовать событие, проверить событие и сохранить его в базе данных. Я хочу обработать файлы в каталоге только один раз, даже если при…
13 июн '16 в 18:49
2
ответа
У новых версий производителей Kafka все еще есть "factory.type"?
В старых версиях документа сказано, что это одно из важнейших свойств. Документ более новой версии не упоминает об этом вообще. Есть ли у более новых версий производителей Kafka еще producer.type? Или новые производители всегда asyncи я должен позво…
25 авг '17 в 03:17
2
ответа
Неизвестная ошибка в программе производителя / потребителя, считаю, что это бесконечный цикл
Я пишу программу, которая решает проблему производителя / потребителя, в частности, версию с ограниченным буфером (я думаю, они имеют в виду одно и то же). Производитель будет генерировать x количество случайных чисел, где x - это параметр командной…
12 апр '10 в 17:16
1
ответ
Производительность Kafka Producer 0.9.0, большое количество потоков ожидания
Мы пишем сообщения со скоростью около 9000 записей в секунду в наш кластер kafka, иногда мы видим, что производительность производителя значительно снижается, а затем никогда не восстанавливается. Когда это происходит, мы видим следующую ошибку "нев…
01 май '16 в 00:23
1
ответ
ActiveMQ http ошибка соединения
Я пытаюсь подключить клиентское приложение java к ActiveMQ через http, но получаю сообщение об ошибке: (полная ошибка внизу) javax.jms.JMSException: Could not post command: ProducerInfo No such field org.apache.activemq.command.ProducerInfo.sentCoun…
11 июн '15 в 09:00
1
ответ
Почему я выдаю 65536 сообщений на кафку, но получаю только сотни?
Версия kafka: 1.0.0 версия sarama: 1.15.0 версия go: 1.9.1 Пример кода, подобный этому: func main() { config := sarama.NewConfig() config.Version = sarama.V1_0_0_0 config.Producer.Return.Successes = true config.Producer.RequiredAcks = sarama.WaitFor…
05 фев '18 в 06:06
1
ответ
Как использовать execl() для выполнения другой программы
У меня есть задание на производителя-потребителя с использованием многопроцессорной и общей памяти У меня есть вопрос, как использовать execl() для выполнения другого файла В моей программе будет 3 файла c parent.c: родительский процесс product.c: п…
04 дек '13 в 17:07
1
ответ
Производитель Потребитель в Java многопоточный
Я пытаюсь реализовать проблему потребителя производителя в Java. Я использую кольцевой буфер (круговой массив), чтобы продюсер вставлял элементы в буфер. Ниже приведен мой код: import java.util.*; import java.io.*; public class Buffer { String a[]; …
06 ноя '13 в 01:54
2
ответа
На MacOSX, в C++, как выполнить межпроцессное взаимодействие через разделяемую память без спин-блокировки?
У меня есть два процесса: Producer and Consumer у них есть общая mmaped общая область памяти Memory Теперь продюсер пишет вещи в память. Потребитель читает вещи из памяти. I would prefer Consumer not to spin wait with Memory is empty. I would prefer…
05 мар '10 в 19:16