Module

Kafka.Kafka

#SaslConfig

type SaslConfig = { mechanism :: String, password :: String, username :: String }

#Kafka

data Kafka :: Type

#KafkaConfig

type KafkaConfig = { brokers :: Array String, clientId :: String, sasl :: Maybe SaslConfig, ssl :: Boolean }

#makeClient

Modules