Hello Flyte community,
I have a question related to cloud events. There is an integration with Kafka, and what I found so far is that you can configure:
- Brokers
- Topic name
- Events types
- Kafka Version
As I can see almost default config is used here:
https://github.com/flyteorg/flyteadmin/blob/master/pkg/async/cloudevent/factory.go#L65-L67
Is there a way to configure Kafka authentication method? Maybe there are hidden ways to do that, for example using env variables?
Sorry, I'm not very familiar with Sarama library which is used for the integration.