feat(Kafka): Add option to login to SASL password-protected Kafka, like MSK#100

Merged

jhutar merged 25 commits intomainfrom msk

Dec 22, 2023

+169-65

Commits on Dec 22, 2023

feat: Add option to send to SASL-enabled clusters like MSK

Smejky338
authored and
jhutar
committed
feat(kafka getTimes): Add option to connect to SASL-enabled clusters like MSK

Smejky338
authored and
jhutar
committed
fix(HBI_populate): Add support for multiple brokers in arg

Smejky338
authored and
jhutar
committed
feat(HBI_utils): Add separate producer for password-protected Kafka

Smejky338
authored and
jhutar
committed
feat: remove duplicate console output

Smejky338
authored and
jhutar
committed
fix(hbi_populate): Wrap in try/catch for attributeException

Smejky338
authored and
jhutar
committed
fix(hbi_utils): Fix order of password vs. nonpassword KafkaProducer

Smejky338
authored and
jhutar
committed
fix(Kafka args): Add Kafka args in both places, don't default to a value

Smejky338
authored and
jhutar
committed
fix(Kafka): Switch to try/except AttributeError for switching of SASL x noauth

Smejky338
authored and
jhutar
committed
feat(kafka): unify using of kafka_host:port

Smejky338
authored and
jhutar
committed
fix linting Kafka_times

Smejky338
authored and
jhutar
committed
fix lint: avoid code duplication

Smejky338
authored and
jhutar
committed
lint fix - post_kafka

Smejky338
authored and
jhutar
committed
fix error message "existing"/"only have"

Smejky338
authored and
jhutar
committed
feat(skip_to_end): Add possibility to use SASL auth into Kafka - for MSK

Smejky338
authored and
jhutar
committed
feat(consumer_lag): Add possibility to use SASL auth into Kafka - for MSK

Smejky338
authored and
jhutar
committed
fix(skip_to_end): fix hash key: value to be a pair

Smejky338
authored and
jhutar
committed
fix: Subscribe to the topic after consumer creation, don't use the config hash as it doesn't work that way

Smejky338
authored and
jhutar
committed
fix(consumer_lag): Remove topic from KafkaConsumer config

Smejky338
authored and
jhutar
committed
fix(kafka): missing doublequote wrap of hash keys

Smejky338
authored and
jhutar
committed
fix(consumer_lag): logging message vars

Smejky338
authored and
jhutar
committed
fix(consumer_lag): wrong timeout var name in logging

Smejky338
authored and
jhutar
committed
feat: default kafka opts username&psw to ""

Smejky338
authored and
jhutar
committed
feat(kafka): avoid try block to use the default value "" of kafka vars

Smejky338
authored and
jhutar
committed
refactor(kafka consumers): Switch to common params hash and put consumer code into separate method, use default kafka username = ""

Smejky338
authored and
jhutar
committed

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

feat(Kafka): Add option to login to SASL password-protected Kafka, like MSK#100

Commits on Dec 22, 2023

feat: Add option to send to SASL-enabled clusters like MSK

feat(kafka getTimes): Add option to connect to SASL-enabled clusters like MSK

fix(HBI_populate): Add support for multiple brokers in arg

feat(HBI_utils): Add separate producer for password-protected Kafka

feat: remove duplicate console output

fix(hbi_populate): Wrap in try/catch for attributeException

fix(hbi_utils): Fix order of password vs. nonpassword KafkaProducer

fix(Kafka args): Add Kafka args in both places, don't default to a value

fix(Kafka): Switch to try/except AttributeError for switching of SASL x noauth

feat(kafka): unify using of kafka_host:port

fix linting Kafka_times

fix lint: avoid code duplication

lint fix - post_kafka

fix error message "existing"/"only have"

feat(skip_to_end): Add possibility to use SASL auth into Kafka - for MSK

feat(consumer_lag): Add possibility to use SASL auth into Kafka - for MSK

fix(skip_to_end): fix hash key: value to be a pair

fix: Subscribe to the topic after consumer creation, don't use the config hash as it doesn't work that way

fix(consumer_lag): Remove topic from KafkaConsumer config

fix(kafka): missing doublequote wrap of hash keys

fix(consumer_lag): logging message vars

fix(consumer_lag): wrong timeout var name in logging

feat: default kafka opts username&psw to ""

feat(kafka): avoid try block to use the default value "" of kafka vars

refactor(kafka consumers): Switch to common params hash and put consumer code into separate method, use default kafka username = ""