bulker
bulker copied to clipboard
feat: allow security protocol
Summary by cubic
Adds support for configuring Kafka security.protocol via BULKER_KAFKA_SECURITY_PROTOCOL to work with secure clusters (e.g., SASL_SSL). No change in default behavior unless the var is set.
- New Features
- New config: KAFKA_SECURITY_PROTOCOL → sets security.protocol when provided.
- Docs: added BULKER_KAFKA_SECURITY_PROTOCOL env var usage.
Please check kafkabase/kafka_config.go:69 Are you sure that these changes are necessary?
I did see that already yes.
The thing is that bulker doesn't support SASL_PLAINTEXT
Up! Thank you