Merge pull request #3 from harisheoran/kafka

fix: Dockerfile ca cert

chat-server/Dockerfile

@@ -16,6 +16,7 @@ WORKDIR /app
 
 COPY --from=build /app/bin/my-chat-system-server /app/bin/my-chat-system-server
 COPY --from=build /app/ui /app/ui
+COPY --from=build /app/ca.pem /app/ca.pem
 
 RUN chmod +x /app/bin/my-chat-system-server
 

chat-server/Dockerfile-test

@@ -0,0 +1,25 @@
+FROM golang:1.23.3 as build
+
+WORKDIR /app
+
+COPY go.mod go.sum ./
+
+RUN go mod download
+
+COPY . .
+
+RUN CGO_ENABLED=0 GOOS=linux GOARCH=amd64 go build -o /app/bin/my-chat-system-server ./cmd/server
+
+FROM ubuntu:24.10 as prod
+
+WORKDIR /app
+
+COPY --from=build /app/bin/my-chat-system-server /app/bin/my-chat-system-server
+COPY --from=build /app/ui /app/ui
+COPY --from=build /app/ca.pem /app/ca.pem
+
+RUN chmod +x /app/bin/my-chat-system-server
+
+EXPOSE 1316
+
+ENTRYPOINT [ "/app/bin/my-chat-system-server" ]

chat-server/cmd/server/chat.go

@@ -92,3 +92,8 @@ func (app *app) produceToKafka() {
 }
 
 // consume message from kafka
+func (app *app) consumeFromKafka() {
+	for {
+
+	}
+}

chat-server/cmd/server/kafka.go

@@ -42,8 +42,7 @@ func (app *app) kafkaInitialize() (*kafka.Dialer, error) {
 	}
 
 	tlsConfig := &tls.Config{
-		RootCAs:            caCertPool,
-		InsecureSkipVerify: false, // Ensure this is false in production.
+		RootCAs: caCertPool,
 	}
 	scram, err := scram.Mechanism(scram.SHA512, username, password)
 	if err != nil {