Showing posts with label Messaging. Show all posts
Showing posts with label Messaging. Show all posts

Tuesday, August 26, 2014

ActiveMQ Introduction

ActiveMQ is a messaging bus and helps in building Event based systems.It supports JMS which is a JavaEE based feature. In this tutorial, we will look into how to install and start a ActiveMQ server and a small program to create topic and consume topic over the message bus. We will also look into the ActiveMQ web front end where we can see what is happening in the message bus. This tutorial is based on windows but pretty much similar steps can be followed for Linux.

Installation of ActiveMQ

Thursday, July 24, 2014

Apache Kafka Tutorial

In this tutorial, we will do a basic installation of Apache Kafka and run one producer and consumer. You can follow the video here

Basic steps of installing and running apache kafka are:
  • Start Zookeeper
bin/zookeeper-server-start.sh config/zookeeper.properties
  • Start Broker
bin/kafka-server-start.sh config/server.properties
  • Topic Creation
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
  • List Topic
bin/kafka-topics.sh --list --zookeeper localhost:2181
  • Start Producer
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test 
  • Start Consumer
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning