@@ -54,11 +54,13 @@ foreign import data Producer :: Type
5454type ProducerConfig
5555 = { idempotent :: Maybe Boolean
5656 , transactionalId :: Maybe String
57+ , maxInFlightRequests :: Maybe Int
5758 }
5859
5960type InternalProducerConfig
6061 = { idempotent :: Nullable Boolean
6162 , transactionalId :: Nullable String
63+ , maxInFlightRequests :: Nullable Int
6264 }
6365
6466foreign import makeClientImpl :: InternalKafkaConfig -> Kafka
@@ -81,6 +83,7 @@ makeProducer k pc = runFn2 makeProducerImpl k ipc
8183 ipc =
8284 { idempotent: toNullable pc.idempotent
8385 , transactionalId: toNullable pc.transactionalId
86+ , maxInFlightRequests : toNullable pc.maxInFlightRequests
8487 }
8588
8689foreign import connectImpl :: Producer -> Effect (Promise Unit)