producer-consumer Questions
13
In Kafka, I would like to use only a single broker, single topic and a single partition having one producer and multiple consumers (each consumer getting its own copy of data from the broker)...
Scabies asked 20/5, 2014 at 5:31
5
Solved
This question seems to be simple, but I want to send an event to notify my user space program that the module buffer is ready to be read.
For example, I have a buffer in my kernel module and its d...
Hexapla asked 7/1, 2014 at 15:32
2
Solved
What is the difference between these two implementations? In which cases should be used one over another?
Crowley asked 30/11, 2014 at 21:53
2
Solved
When a new consumer/brorker is added or goes down, Kafka triggers a rebalance operation. Is Kafka Rebalancing a blocking operation. Are Kafka consumers blocked while a rebalancing operation is in p...
Djerba asked 28/11, 2014 at 4:1
5
Solved
So I have simulated my producer consumer problem and I have the code below. My question is this: how does the consumer stops if he's in constant while(true).
In the code below, I've added
if (qu...
Remus asked 27/4, 2012 at 14:47
4
Solved
So I have seen a lot of ways of implementing one consumer and many producers in Go - the classic fanIn function from the Concurrency in Go talk.
What I want is a fanOut function. It takes as a pa...
Cruces asked 5/6, 2013 at 1:43
2
Solved
I'm experimenting with TPL Dataflow before porting it into my production code.
The production code is a classical producer/consumer system - producer(s) produce messages (related to financial domai...
Heliogabalus asked 31/10, 2016 at 10:21
2
Solved
I run a pretty typical producer/consumer model on different tasks.
Task1: Reads batches of byte[] from binary files and kicks off a new task for each collection of byte arrays. (the operation is ...
Unwinking asked 15/6, 2012 at 14:46
5
Solved
I am interested in a data structure identical to the Java BlockingQueue, with the exception that it must be able to batch objects in the queue. In other words, I would like the producer to be able ...
Vassal asked 27/2, 2012 at 14:23
1
Is there a built-in or robust third-party abstraction for consumer that returns value in Java 8+?
P.S. For deferred execution it may return Future as well.
Update. Function interface has a perfec...
Centra asked 30/7, 2019 at 8:13
3
Solved
Why is await queue.get() blocking?
import asyncio
async def producer(queue, item):
await queue.put(item)
async def consumer(queue):
val = await queue.get()
print("val = %d" % val)
async def ...
Hippocrates asked 30/5, 2019 at 11:25
2
Because NServiceBus doesn't seem to support adding a priority mechanism to the message queue, I want to implement this myself.
Command handler (Producer):
public void Handle(DoAnAction message)...
Taneka asked 9/4, 2019 at 10:32
3
Solved
From my main I am starting two threads called producer and consumer. Both contains while(true) loop. Producer loop is UDP Server hence it does not require sleep. My problem is in the Consumer loop....
Evonevonne asked 27/1, 2019 at 23:57
1
I trying to create a consumer level timeout in Active MQ (version 5.15.0). Consider one message is picked by a consumer but not able to acknowledge so in that case i want consumer to timeout so tha...
Endocentric asked 3/10, 2018 at 2:29
3
Solved
The TryDequeue in ConcurrentQueue<T> will return false if no items in queue.
If the queue is empty I need that my queue will wait until new item to be added in queue and it dequeue that new o...
Previous asked 16/2, 2011 at 8:24
2
Solved
I have a producer that I want to distribute work consistently across consumers by consistent hashing. For example, with consumer nodes X and Y, tasks A, B, C should always go to consumer X, and D, ...
Chancey asked 1/9, 2010 at 20:10
1
I am facing an issue while consuming message using the bootstrap-server i.e. Kafka server. Any idea why is it not able to consume messages without zookeeper?
Kafka Version: kafka_2.11-1.0.0
Zooke...
Edp asked 20/3, 2018 at 17:31
1
Solved
See the following classical producer-consumer code:
int main()
{
std::queue<int> produced_nums;
std::mutex m;
std::condition_variable cond_var;
bool done = false;
bool notified = false;...
Plenum asked 21/5, 2018 at 7:57
3
Solved
I am trying to execute a sample producer consumer application using Apache Kafka. I downloaded it from https://www.apache.org/dyn/closer.cgi?path=/kafka/0.10.0.0/kafka-0.10.0.0-src.tgz . Then I sta...
Ashtray asked 30/6, 2016 at 7:53
2
Solved
I`ve been reading about the principles of AMQP messaging confirms. (https://www.rabbitmq.com/confirms.html). Really helpful and wel written article but one particular thing about consumer aknowledg...
Untried asked 5/4, 2018 at 12:30
1
Solved
I stumbled upon this article on IBM - developerworks, and the code they posted had me raise some questions:
Why is the building of the local variable Map wrapped within a synchronized block? Note...
Anemone asked 16/3, 2018 at 21:22
1
We have a running/production system, where an int32 protobuf field is being communicated to and fro between components. We need to update it to int64 on the fly without getting the current system d...
Imco asked 26/2, 2018 at 11:25
1
Title is too broad but I couldn't find a more specific one, please feel free to change with better one.
I have a table which is working with sequences instead identity. I have three producer appli...
Seamark asked 29/11, 2017 at 6:52
6
Solved
I have a single thread producer which creates some task objects which are then added into an ArrayBlockingQueue (which is of fixed size).
I also start a multi-threaded consumer. This is build as a...
Bethina asked 23/1, 2012 at 16:5
1
How can I implement the Producer/Consumer patterns in C# using Events and Delegates? What do I need to keep an eye out for when it comes to resources when using these design patterns? Are there any...
Antibes asked 9/4, 2009 at 11:24
© 2022 - 2024 — McMap. All rights reserved.