<#3220 [Core feature] Kafka Authentication> Issue ...
# flyte-github
a
#3220 [Core feature] Kafka Authentication Issue created by pingsutw Motivation: Why do you think this is important? In flyteadmin, we send a cloud event to Kafka. However, we don't have any authentication for Kafka right now. we should expose auth config, use
Sarama
api to read the config, and send the request to Kafka. Goal: What should the final outcome look like, ideally? CloudEvent Config
Copy code
cloudevents:
    enable: true
    kafka:
      brokers: <kafka_ip>
      version:  1.2.1
      security_ protocol: SASL_SSL
      sasl_config: <config for SASL>
Describe alternatives you've considered NA Propose: Link/Inline OR Additional context Slack Thread: • https://flyte-org.slack.com/archives/CP2HDHKE1/p1667307468058299https://flyte-org.slack.com/archives/CP2HDHKE1/p1667412056307629https://flyte-org.slack.com/archives/CP2HDHKE1/p1670577684352189https://flyte-org.slack.com/archives/CP2HDHKE1/p1667412056307629 Authentication Methods Overview Are you sure this issue hasn't been raised already? ☑︎ Yes Have you read the Code of Conduct? ☑︎ Yes flyteorg/flyte