*

cmd/main.go

@@ -2,11 +2,11 @@ package main
 
 import (
 	"context"
-	"fmt"
 	"log"
 	"net"
 	"os"
 	"os/signal"
+	"strconv"
 	"syscall"
 	"test3k/authDB/internal/config"
 	server "test3k/authDB/internal/transport/grpc"
@@ -55,7 +55,7 @@ func start(config *config.Config, s *grpc.Server, srv *server.AuthDBServer) {
 	api.RegisterAuthDBServer(s, srv)
 
 	//
-	connStr := fmt.Sprintf(":%d", config.App.Port)
+	connStr := net.JoinHostPort("", strconv.Itoa(config.App.Port))
 	lis, era := net.Listen("tcp", connStr)
 	if era != nil {
 		log.Fatal(era)
@@ -67,6 +67,6 @@ func start(config *config.Config, s *grpc.Server, srv *server.AuthDBServer) {
 	//
 	eru := s.Serve(lis)
 	if eru != nil {
-		log.Fatal(eru)
+		log.Fatal("Failed starting server")
 	}
 }

deploy/docker-compose.yml

@@ -0,0 +1,19 @@
+version: '2'
+services:
+  zookeeper:
+    image: wurstmeister/zookeeper
+    ports:
+      - "2181:2181"
+  kafka:
+    build: .
+    ports:
+      - "9094:9094"
+    environment:
+      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
+      KAFKA_LISTENERS: INTERNAL://kafka:9092,OUTSIDE://kafka:9094
+      KAFKA_ADVERTISED_LISTENERS: INTERNAL://kafka:9092,OUTSIDE://localhost:9094
+      KAFKA_INTER_BROKER_LISTENER_NAME: INTERNAL
+      KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: INTERNAL:PLAINTEXT,OUTSIDE:PLAINTEXT
+      KAFKA_CREATE_TOPICS: "abcd:2:1"
+    volumes:
+      - /var/run/docker.sock:/var/run/docker.sock