docker search rabbitmq:management

docker pull rabbitmq:management

docker run -di --name=tensquare_rabbitmq -p 5672:5672 -p 5671:5671 -p 4369:4369 -p 15671:15671 -p 15672:15672 -p 25672:25672 rabbitmq:managementd

15671 managem

package main

import (
    "context"
    "fmt"
    "log"
    "os"
    "os/signal"
    "syscall"
    "time"

    "github.com/segmentio/kafka-go"
)

var (
    topic  = "user_click&quo

version: "2"

services:
  zookeeper:
    image: docker.io/bitnami/zookeeper:3.8
    ports:
      - "2181:2181"
    environment:
      - ALLOW_ANONYMOUS_LOGIN=yes
  kafka-node1:
    image: docker.io/bitnami/kafka:3.4
    ports:
      - "9092:9092"
      - "9094: