chore(all): small tweaks

Author: absorbb

bulker/kafkabase/kafka_config.go

@@ -48,15 +48,15 @@ type KafkaConfig struct {
 	ProducerBatchSize          int     `mapstructure:"PRODUCER_BATCH_SIZE" default:"65535"`
 	ProducerLingerMs           int     `mapstructure:"PRODUCER_LINGER_MS" default:"1000"`
 	ProducerWaitForDeliveryMs  int     `mapstructure:"PRODUCER_WAIT_FOR_DELIVERY_MS" default:"1000"`
-	
+
 	// Failover logger configuration
 	FailoverLoggerEnvConfig `mapstructure:",squash"`
 }
 
 // GetKafkaConfig returns kafka config
 func (ac *KafkaConfig) GetKafkaConfig() *kafka.ConfigMap {
 	if ac.KafkaBootstrapServers == "" {
-		panic("❗️Kafka bootstrap servers are not set. Please set BULKER_KAFKA_BOOTSTRAP_SERVERS env variable")
+		panic("❗️Kafka bootstrap servers are not set. Please set KAFKA_BOOTSTRAP_SERVERS env variable")
 	}
 	kafkaConfig := &kafka.ConfigMap{
 		"client.id":                "bulkerapp",

bulker/operator/operator.go

@@ -500,6 +500,8 @@ func (o *Operator) createDeploymentFromData(data *DeploymentData) error {
 	// Create Service
 	if err := o.createOrUpdateServiceFromData(ctx, data); err != nil {
 		return fmt.Errorf("failed to create service: %v", err)
+	} else {
+		o.Infof("Service for deployment %s created/updated", data.DeploymentID)
 	}
 
 	// Create HPA if enabled
@@ -585,6 +587,8 @@ func (o *Operator) updateDeploymentFromData(data *DeploymentData, existing *Depl
 	// Update Service
 	if err := o.createOrUpdateServiceFromData(ctx, data); err != nil {
 		return fmt.Errorf("failed to update service: %v", err)
+	} else {
+		o.Infof("Service for deployment %s created/updated", data.DeploymentID)
 	}
 
 	// Update HPA if enabled

services/rotor/build.mts

@@ -39,7 +39,7 @@ esbuild
       format: "cjs",
       outfile: "./dist/functions-server.js",
       sourcemap: false,
-      // minify: true,
+      minify: true,
       external: externalModules,
       logLevel: "info",
     });

services/rotor/src/lib/retries.ts

@@ -71,7 +71,6 @@ export function retryLogMessage(retryPolicy: retryPolicy, retries: number): stri
 export function retryObject(e: Error & { retryPolicy?: retryPolicy }, retries: number) {
   if (e.name === DropRetryErrorName || e.name === RetryErrorName) {
     const retryPolicy = getRetryPolicy(e);
-    console.log("Retry policy: " + JSON.stringify(retryPolicy));
     const retryTime = retryBackOffTime(retryPolicy, retries + 1);
     return { retry: { left: retryPolicy.attempts - retries, ...(retryTime ? { time: retryTime } : {}) } };
   } else {