local

Consuming and publishing kafka messages in spring boot In the last blog we saw how to bring up a kafka cluster on local and publish-consume messages using kafka-console commands. In this blog we will take a look at how to connect your spring boot application to kafka cluster and publish-consume messages via it. Let’s start by creating producer first Go to https://start.spring.io/ Select Spring Web and Spring for Apache Kafka dependencies and generate the project Next open project in any of the code editor Now, we will have to create a kafka config, to do that create a PublisherConfig class...

According to Kafka website, “Apache Kafka is an open-source distributed event streaming platform used by thousands of companies for high-performance data pipelines, streaming analytics, data integration, and mission-critical applications” Before diving into how kafka works and how to configure it for your specific use case, we will learn as part of this blog on how to bring up a kafka cluster on a local dev machine along with zookeeper and publishing-consuming events using kafka-console commands....