v0.0.2.5 Изменен хост kafka

server.go

@@ -332,7 +332,7 @@ func (s *server) StreamMessages(req *proto.StreamMessagesRequest, stream proto.M
 	log.Printf("Starting message stream for user %d", req.UserId)
 
 	reader := kafka.NewReader(kafka.ReaderConfig{
-		Brokers:  []string{"kafka:9092"},
+		Brokers:  []string{"89.104.69.222:9092"},
 		Topic:    "user_messages",
 		GroupID:  fmt.Sprintf("user-%d", req.UserId),
 		MinBytes: 10e3,
@@ -386,7 +386,7 @@ func main() {
 
 	// Initialize Kafka producer
 	producer := &kafka.Writer{
-		Addr:     kafka.TCP("kafka:9092"),
+		Addr:     kafka.TCP("89.104.69.222:9092"),
 		Topic:    "user_messages",
 		Balancer: &kafka.Hash{},
 	}