Spring Cloud Bus Example

Here I am going to build an application to show how to use Spring Cloud Bus. Let’s say you have multiple applications reading properties using Spring Cloud Config from centralized configuration files (for example, from Git repository). Spring Cloud Config is where you can have not only your all configurations centrally managed but also you can refresh them dynamically and which in turn can be picked by your referencing applications from the very next moment. So in central configurations using Spring Cloud Config, for each module if there is any…

Continue

Python Client for Apache Kafka Producer and Consumer

Introduction In this tutorial I am going to show you how to use Python client to work with Apache kafka distributed stream processing system. I will create Kafka producer and consumer examples using Python language. KafkaConsumer is a high-level message consumer that consumes records from a kafka cluster. The consumer is not thread safe and should not be shared across threads.

Continue

Event Driven Streaming using Spring Cloud Stream and Apache Kafka

In this tutorial we will see an example of event driven streaming using Spring Cloud Stream and Apache Kafka streaming platform. How do we deal with some events, such as, a new user has registered to a portal, an order was placed, a file has been uploaded etc? Let’s say when an order was placed then we need a call to process payment, a call to reserve inventory, a call to begin the process of packaging, picking and shipping the product. For a few orders it’s not a big deal…

Continue

Apache Kafka Streams for building Real Time Data Processing with STOMP over WebSocket using Spring Boot and Angular 8

Introduction In this tutorial I will show you how to work with Apache Kafka Streams for building Real Time Data Processing with STOMP over Websocket using Spring Boot and Angular 8. We will see how to build push notifications using Apache Kafka, Spring Boot and Angular 8. We need to provide some basic things that Kafka Streams requires, such as, the cluster information, application id, the topic to consume, Serdes to use, and so on. I will show you how to build the application using both gradle and maven build…

Continue

How to produce and consume message using Apache Kafka and Spring Boot

Introduction In this tutorial I will show you how to produce and send message using Apache Kafka and Spring Boot. Apache Kafka is supported by providing auto-configuration of the spring-kafka project. Kafka configuration is controlled by external configuration properties in spring.kafka.*. I will show you how to build this application using both maven and gradle build tools. I will create a new topic on application start up. You need to make sure that ZooKeeper server and Kafka server or broker are running. You also need to make sure that a…

Continue

How to setup and work with Publish Subscribe domain in Apache Kafka in Windows Environment

Introduction In this guide I will tell you how to setup and work with publish subscribe domain in Apache Kafka in windows environment. I am not going to tell you about Kafka and you will find very good documentation on this here. Kafka works on publish subscribe domain and this tutorial will show you how to create topic, how to send or publish messages, how to consume messages etc using command line tool.

Continue

Publish Subscribe Message onto MQTT using Spring Boot

Introduction We will see an example here how to publish and subscribe message onto MQTT (Mosquitto) using Spring Boot framework. We had seen in our previous example how to publish and subscribe message using Mosquitto client – MQTT.fx. So here we are going to ingrate Spring application with MQTT broker through Spring integration framework, though the style of programming is not a typical Spring integration programming. We have discussed what is Mosquitto (MQTT broker) or how it is useful in introduction section of the tutorial where I had shown how…

Continue

Publish Subscribe Message using Mosquitto Client – MQTT.fx

Introduction Here we will see how to publish subscribe message using Mosquitto client – MQTT.fx. You can use any server side technologies such as Java, Spring, Python etc. to publish and subscribe message into MQTT topic but here we will use MQTT client, which is downloadable for various operating system, to publish or to subscribe message. You need to make sure that your Mosquitto server is running before you connect to the server using MQTT.fx client tool.

Continue

How to Install Mosquitto MQTT Client in Windows

Introduction In this post we will see how to install Mosquitto MQTT Client or MQTT.fx in Windows environment. In our previous tutorial we have seen how to install Mosquitto server. MQTT.fx is an user interface through which you can check messages arrive on topics. You have the option to connect to, disconnect from Mosquitto server. You can also subscribe to and unsubscribe from a particular topic. You have the option to clear all topics.

Continue