Kafka.Producer

data Producer :: Type

type ProducerConfig = { idempotent :: Maybe Boolean, maxInFlightRequests :: Maybe Int, transactionalId :: Maybe String }

makeProducer :: Kafka -> ProducerConfig -> Producer

connect :: Producer -> Aff Unit

type ProducerMessage = { key :: Maybe String, partition :: Maybe Partition, value :: String }

type ProducerBatch = { messages :: Array (ProducerMessage), topic :: Topic }

type InternalProducerMessage = { key :: Nullable String, partition :: Nullable Int, value :: String }

type InternalProducerBatch = { messages :: Array (InternalProducerMessage), topic :: String }

toInternalProducerMessage :: ProducerMessage -> InternalProducerMessage

toInternalProducerBatch :: ProducerBatch -> InternalProducerBatch

data RecordMetadata :: Type

send :: Producer -> ProducerBatch -> Aff (Array RecordMetadata)

disconnect :: Producer -> Aff Unit