kafka-to-postgresql: Postgres not yet available: pq: database "sslmode=true" does not exist

[desertspider]

Expected Behavior

I am testing kafka-to-postgresql. I get the following Error:

kafka-to-postgresql: Postgres not yet available: pq: database "sslmode=true" does not exist

My docker compose:

  kafka-to-postgresql:
    image: a0aa3649a177
    restart: always
    environment:
     - DRY_RUN=false
     - KAFKA_BOOTSTRAP_SERVER=kafka:9092
     - KAFKA_LISTEN_TOPIC=^ia.+
     - POSTGRES_HOST='azuretenant.postgres.database.azure.com'
     - POSTGRES_PORT=5432
     - POSTGRES_SSLMODE=true
     - POSTGRES_USER=username
     - POSTGRES_PASSWORD=password
     - POSTGRES_DB=FACTORYINSIGHT_DATABASE
    depends_on:
     - kafka

POSTGRES_SSLMODE to false gives the same error, only with database sslmode=false

Clearly it uses the ssl mode als database name.

I pulled the latest code from git and compiled all the images with "compile_all_containers.sh"

If i use the Postgres 12 default docker compose database, i get errors that SSL is not enabled (even if i set SSLMODE to false)

Current Behavior

.

Relevant log output

No response

Steps to Reproduce

.

Context (Environment)

.

Possible Solution

No response

Version

not applicable

Anything else?

No response

[Scarjit]

The key should be POSTGRES_DATABASE instead of POSTGRES_DB.

We should make it give out an better error if it not set.

united-manufacturing-hub/golang/cmd/kafka-to-postgresql/main.go

Lines 75 to 87 in ebea6e0

	// Postgres
	PQHost := os.Getenv("POSTGRES_HOST")
	PQPort := 5432
	PQUser := os.Getenv("POSTGRES_USER")
	PQPassword := os.Getenv("POSTGRES_PASSWORD")
	PWDBName := os.Getenv("POSTGRES_DATABASE")
	PQSSLMode := os.Getenv("POSTGRES_SSLMODE")
	if PQSSLMode == "" {
	PQSSLMode = "require"
	} else {
	zap.S().Warnf("Postgres SSL mode is set to %s", PQSSLMode)
	}

[desertspider]

Good catch. I just copied the compose commands from
deployment/kafka-to-postgresql/docker-compose.yml
without checking the ENV variables. Changing to POSTGRES_DATABASE fixes the problem.