I am trying to use Kafka. All configurations are done properly but when I try to produce message from console I keep getting the following error WARN Error while fetching metadata with correlation...

I work on a bench of my Kafka cluster in version 1.0.0-cp1. In part of my bench who focus on the max throughput possible with ordering guarantee and no data loss (a topic with only one partition),...

I have a two-nodes Kafka cluster (EC2 instances) where each node is used as a separate broker. When I run a producer on the leader instance with the following command: kafka-console-producer.sh --...

I'm using Spring-Kafka version 1.2.1 and, when the Kafka server is down/unreachable, the asynchronous send calls block for a time. It seems to be the TCP timeout. The code is something like this: ...

How to upload the data from csv to aws kinesis using boto3 I have tried three methods and it is all working for me. To upload the data from csv to kinesis in chunks. Upload the random generated da...

I have a requirement to upgrade our Producer/Consumer infrastructure. The current setup look like this: Set of 3 queues with different priority (low, med, high). When one our customers generate ...

I have built a kafka docker container and orchestrate it using docker-compose. Calling docker ps I get the following putput: CONTAINER ID IMAGE COMMAND CREATED STATUS PORTS NAMES 5bde6f76...

I have downlaoded oData4J jar files from odata.org and I intend to do a sample producer, within a basic web service. I assumed that InMemoryProducerExample.java from http://code.google.com/p/odat...

I'm using RabbitMQ with Arduino for the first time and I need to publish data. So I've used the PubSubCLient class. This is the code: #include <SPI.h> #include <PubSubClient.h> #includ...

I would like to create a Spring's bean producer method which is aware who invoked it, so I've started with the following code: @Configuration public class LoggerProvider { @Bean @Scope("prototy...

I need to use something to coordinate my system with several consumers/producers each running on different machines with different operating systems. I have been researching on using MySql to do th...

I have a situation where different threads populate a queue (producers) and one consumer retrieve element from this queue. My problem is that when one of these elements are retrieved from the queue...

Im using Generic.Queue in C# 3.0 and Monitor.Enter,wait,exit for wait before consuming the queue (wait for the element to be enqueued). Now im moving to C# 4. Can anyone suggest me which one...

I have two processes: Producer and Consumer they have a commonly mmaped shared region of memory Memory Now, Producer writes stuff to Memory. Consumer reads stuff from Memory. I would prefer ...