Vectormike

docker run --name rabbitmq -p 5672:5672 rabbitmq

Vectormike

 "scripts": {
    "publish": "node producer.js",
    "consume": "node consumer.js"
  },

Vectormike

const ampq = require('amqplib');

const connect = async () => {
	try {
		// Connect to RabbitMQ
		const connection = await ampq.connect('amqp://localhost:5672');

		// Create channel
		const channel = await connection.createChannel();

Vectormike

const ampq = require('amqplib');

// Get text from command line
const text = process.argv[2] || 'Nothing to do.';

const connect = async () => {
	try {
		// Connect to RabbitMQ
		const connection = await ampq.connect('amqp://localhost:5672');

Vectormike

npm i amqplib

Vectormike

const { Kafka } = require('kafkajs');

const run = async () => {
	try {
		const kafka = new Kafka({
			clientId: 'kafkaApp',
			brokers: ['127.0.0.1:9092'],
		});

		const consumer = kafka.consumer({ groupId: 'teamA' });

Vectormike

const { Kafka } = require('kafkajs');

const run = async () => {
	try {
		const kafka = new Kafka({
			clientId: 'kafkaApp',
			brokers: ['127.0.0.1:9092'],
		});

		const producer = kafka.producer();

Vectormike

const { Kafka } = require('kafkajs');


const run = async () => {
	try {
		const kafka = new Kafka({
			clientId: 'kafkaApp',
			brokers: ['127.0.0.1:9092'],
		});

Vectormike

$ docker run --name kafka -p 9092:9092 \
-e KAFKA_ZOOKEEPER_CONNECT=172.17.0.2:2181 \
-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://127.0.0.1:9092 \
-e KAFKA_OFFSETS_TOPICS_REPLICATION_FACTOR=1 confluentinc/cp-kafka

Vectormike

$ docker inspect zookeeper --format='{{ .NetworkSettings.IPAddress}}'
> 172.17.0.2