Showing posts with label Message Broker. Show all posts
Showing posts with label Message Broker. Show all posts
Wednesday, April 15, 2020

Kafka poll() vs heatbeat()

›
In older versions of Kafka, the consumer was responsible for polling the broker frequently to prove that it is still alive. If the consumer...
Saturday, September 08, 2018

Ruminating on Kafka consumer parallelism

›
Many developers struggle to understand the nuances of parallelism in Kafka. So jotting down a few points that should help from the Kafka do...
Wednesday, July 18, 2018

Creating a RabbitMQ pipeline using listeners/publishers

›
In Event Driven Architectures, you often have to create a pipeline of event processing. One of my teams was using Spring AMQP libary and wa...
Saturday, March 10, 2018

Identifying RabbitMQ consumers

›
One of the challenges my team was facing was to accurately identify the consumers of a RabbitMQ queue. Let's say if you have 5 consumer...
Monday, October 09, 2017

Handling RabbitMQ broker re-connections

›
The RabbitMQ Java Client Library has default support for auto-recovery (since version 4.0.0). Hence the client will try to recover a broke...

Handling MQTT broker re-connections

›
Any client that connects to an MQTT broker needs the ability to handle a connection failure. The popular Eclipse Paho library now has sup...
Sunday, October 08, 2017

Ruminating on MQTT load balancing for scalable IoT event processing

›
MQTT brokers support the publish/subscribe paradigm. But what if you need to scale out the processing of MQTT messages over a cluster of no...
Thursday, December 22, 2016

Ruminating on AMQP internals and JMS equivalent semantics

›
Many Java developers often use JMS APIs to communicate with the message broker. The JMS API abstracts away the internal implementation comp...
Thursday, December 01, 2016

Concurrency and scaling strategies for MDPs and MDBs

›
Message Driven Beans offer a lot of advantages over a standalone JMS consumer as listed in this blog-post . The Spring framework provides u...

Implementing a Request Response with Messaging (JMS)

›
Quite often, we need to implement a request/response paradigm on JMS - e.g. calling a backend function on a mainframe or a third-party inte...
Monday, September 22, 2014

Exploring Apache Kafka..

›
We had successfully used ActiveMQ and RabbitMQ in many projects and never felt the need to explore any other message broker. Today, my coll...