Add mongoDB as docker container - Update readme.md

Author: Hugo Rojas

Makefile

@@ -1,4 +1,4 @@
-run-containers:
+init-containers:
 	docker compose up --build -d
 
 start-zookeeper:
@@ -11,4 +11,13 @@ run-producer:
 	go run cmd/producer/main.go
 
 run-consumer:
-	go run cmd/consumer/main.go
+	go run cmd/consumer/main.go
+
+stop-containers:
+	docker compose down --remove-orphans
+
+send-request:
+	curl --header "Content-Type: application/json" \
+  --request POST \
+  --data '{"title": "Golang Boss Engineer in Docker","description": "This a Boss position for Docker","company": "Sarama Docker","salary": "70.000"}' \
+  http://localhost:9600/jobs

README.md

@@ -0,0 +1,14 @@
+Phase I
+
+# mark Segmentio messages
+
+# update README.md
+
+Phase II
+
+# Add more features (channels)
+
+1. run `make init-containers`
+2. Terminal 1: run `make run-producer`
+3. Terminal 1: run `make run-consumer`
+4. Terminal 3: run `make send-request`

docker-compose.yml

@@ -38,6 +38,28 @@ services:
       - zookeeper
     networks:
       - products_network
+  mongodb:
+    image: mongo:latest
+    restart: always
+    environment:
+      MONGODB_DATABASE: dockerKafka
+    ports:
+      - 27018:27018
+    volumes:
+      - mongodb_data_container:/data/db
+    networks:
+      - products_network
+  # mongo-express:
+  #   image: mongo-express
+  #   restart: always
+  #   ports:
+  #     - 8081:8081
+  #   environment:
+  #     ME_CONFIG_MONGODB_ADMINUSERNAME: root
+  #     ME_CONFIG_MONGODB_ADMINPASSWORD: example
+  #     ME_CONFIG_MONGODB_URL: mongodb://root:example@mongo:27018/
+volumes:
+  mongodb_data_container:
 networks:
   products_network:
     driver: bridge

pkg/config/env.example

@@ -1,10 +1,12 @@
 PORT=9600
+SERVERTIMEOUT = 5
 KAFKAURL="localhost:9092"
 KAFKASERVER="bootstrap.servers"
-KAFKATOPIC="jobs-confluentic-1"
+KAFKATOPIC="jobs-1"
 KAFKAGROUPID="group-id-1"
 KAFKARESETPOLICY="earliest"
 MONGODBURL="localhost:27017"
 MONGODB="kafkamongo"
 MONGOCOLLECTION="jobs"
-MONGOTIMEOUT=2
+MONGOTIMEOUT=5
+BROKER="sarama"

pkg/database/init.go

@@ -12,27 +12,9 @@ import (
 
 type DB struct {
 	client *mongo.Client
-	// session    *mgo.Session
-	// collection *mgo.Collection
 }
 
 func Connect(cf *config.Configuration) (*DB, error) {
-	// settings := &mgo.DialInfo{
-	// 	Addrs:    []string{"localhost:27017"},
-	// 	Timeout:  3 * time.Second,
-	// 	Database: "animals",
-	// 	Username: "",
-	// 	Password: "",
-	// }
-
-	// s, err := mgo.Dial("mongodb://localhost:27017")
-	// if err != nil {
-	// 	return nil, err
-	// }
-	// c := s.DB(cf.MONGODB).C(cf.MONGOCOLLECTION)
-
-	// return &DB{session: s, collection: c}, nil
-
 	client, err := mongo.NewClient(options.Client().ApplyURI("mongodb://localhost:27017"))
 	if err != nil {
 		log.Fatal(err)

pkg/database/mongo.go

@@ -8,10 +8,9 @@ import (
 )
 
 func (db *DB) SaveJob(job *model.Job) error {
-	// return db.collection.Insert(job)
 	log.Println("Saving job to MongoDB")
-	col := db.client.Database("kafka").Collection("jobs")
-	_, err := col.InsertOne(context.Background(), job)
+	coll := db.client.Database("dockerKafka").Collection("jobs")
+	_, err := coll.InsertOne(context.Background(), job)
 	if err != nil {
 		return err
 	}