Default the username if not present.

Dockerfile.hinfo

@@ -12,11 +12,11 @@ COPY python/lsst/consdb/hinfo.py ./hinfo/
 #   INSTRUMENT: LATISS, LSSTComCam, LSSTComCamSim, LSSTCam
 #   POSTGRES_URL: SQLAlchemy connection URL
 #   KAFKA_BOOTSTRAP: host:port of bootstrap server
-#   KAFKA_USERNAME: username for SASL_PLAIN authentication
 #   KAFKA_PASSWORD: password for SASL_PLAIN authentication
 #   SCHEMA_URL: Kafkit registry schema URL
 # Optional environment variables:
-#   BUCKET_PREFIX: "rubin:" at USDF
+#   BUCKET_PREFIX: set to "rubin:" at USDF, default is ""
 #   KAFKA_GROUP_ID: name of consumer group, default is "consdb-consumer"
+#   KAFKA_USERNAME: username for SASL_PLAIN authentication, default is "consdb"
 
 ENTRYPOINT [ "bash", "-c", "source loadLSST.bash; setup obs_lsst; python ./hinfo/hinfo.py" ]

python/lsst/consdb/hinfo.py

@@ -246,7 +246,7 @@ def get_kafka_config() -> KafkaConfig:
     return KafkaConfig(
         bootstrap=os.environ["KAFKA_BOOTSTRAP"],
         group_id=os.environ.get("KAFKA_GROUP_ID", "consdb-consumer"),
-        username=os.environ["KAFKA_USERNAME"],
+        username=os.environ.get("KAFKA_USERNAME", "consdb"),
         password=os.environ["KAFKA_PASSWORD"],
         schema_url=os.environ["SCHEMA_URL"],
     )
@@ -324,6 +324,7 @@ async def main() -> None:
             auto_offset_reset="earliest",
             isolation_level="read_committed",
             security_protocol="SASL_PLAINTEXT",
+            sasl_mechanism="SCRAM-SHA-512",
             sasl_plain_username=kafka_config.username,
             sasl_plain_password=kafka_config.password,
         )