feat(HBI): Use retries and timeout from args in KafkaProducer (#120)

* fix(skip_to_end): Supply server port as well

* refactor(post_kafka): Unify Kafka_host assignment to before common_params

* fix(get_kafka): Omit list bracets in non-pointer supplying to Kafka

* feat(skelet): Add INFO output option

* lint(skip_to_end)

* fix(post_kafka): Give back kafka_ prefix

* feat(skelet setup): Rename --info to --verbose to be unified with others

* fix(skip_end): Omit explicit logging level logic, use what's in skelet already

* feat(HBI): Use retries and timeout from args in KafkaProducer

opl/hbi_utils.py

@@ -199,12 +199,16 @@ def gen_send_verify(args, status_data):
                 sasl_mechanism="SCRAM-SHA-512",
                 sasl_plain_username=args.kafka_username,
                 sasl_plain_password=args.kafka_password,
+                request_timeout_ms=args.kafka_request_timeout_ms,
+                retries=args.kafka_retries,
             )
         else:
             logging.info(f"Creating passwordless producer to {args.kafka_host}")
             producer = kafka.KafkaProducer(
                 bootstrap_servers=kafka_host,
                 api_version=(0, 10),
+                request_timeout_ms=args.kafka_request_timeout_ms,
+                retries=args.kafka_retries,
             )
 
         status_data.set("parameters.kafka.bootstrap", kafka_host)