Kafka.Kafka

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

data Kafka :: Type

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

makeClient :: KafkaConfig -> Kafka