consumer Examples and Free Source Code

How to select starting offset in Pykafka simpleconsumer?...

python apache-kafka consumer pykafka

consumer class not writing to list Multi threaded application Java...

java multithreading threadpool consumer

Kafka Consumer: Pros and cons of using auto commit...

apache-kafka commit consumer

Why does an async consumer called in __init__ in a Tornado RequestHandler behave differently from st...

python asynchronous tornado consumer

We read data from brokers through multiple consumers using consumer group, but how the consumed data...

apache-kafka kafka-consumer-api consumer

How can an interprocess producer consumer message passing mechanism be protected against corruption ...

windows synchronization interprocess consumer producer

Differentiate which queue was called when using wildcards in apache camel...

java apache-camel activemq-classic wildcard consumer

How to avoid creating an excess of agents when reading their characteristics from a CSV file...

csv netlogo consumer agent-based-modeling

RabbitMQ with Arduino Uno...

arduino rabbitmq arduino-uno consumer producer

Reading messages offset in Apache Kafka...

java offset apache-kafka consumer

Sprint Boot - Post a single string/enum to a REST service...

rest spring-boot http-post consumer

Pact JVM Junit Consumer Compilation Error...

java junit consumer pact

kafka : How to delete data which already been consumed by consumer?...

apache-kafka consumer

Why kafka 0.10 console producer cannot send messages to kafka 0.9?...

java apache-kafka versions consumer producer

How to use consumer and supplier instead Reflection in java 8...

java reflection consumer

when the amount of messages reach the maxsize of retention.bytes ,the kafka will delete messages,the...

apache-kafka consumer

Why does this consumer (running on a servlet) not receive any messages from the kafka topic?...

java servlets apache-kafka consumer

Multiple Producer Multiple Consumer lock-free (or even wait-free) queue...

.net multithreading queue consumer producer

What is an elegant way of halting consumption of messages gracefully in the C# client for RabbitMQ?...

c#rabbitmq messaging amqp consumer

Subscribe method is throwing error while trying to access kafka (0.90 version) from kafka (0.10 vers...

apache-kafka subscribe consumer

RabbitMQ Consumer error message...

java rabbitmq consumer

Mimic C# Actions in Java 8...

java c#action consumer

Why Java's Optional doesn't call Consumer in ifPresent()?...

java lambda java-8 option-type consumer

MultiThreading producer/consumer...

c++multithreading winapi consumer producer

Consuming Spring Hateoas Pageable...

java rest hateoas spring-hateoas consumer

Which Azure service to use for processing data from Event Hub?...

azure events consumer azure-eventhub

Not able to get mutex locks to prevent threads from accessing a function...

c mutex semaphore consumer producer

One JMS Consumer stops listening active mq topic while second do not...

spring jms activemq-classic consumer jms-topic

C: Producer / Consumer...

c pthreads mutex consumer producer

Can I register a listener on MessageConsumer and then call the receive() method? (JMS)...

java concurrency jms listener consumer