ProduceRequest
Namespace: Kafunk
Parent Module: Protocol
Record Fields
| Record Field | Description |
requiredAcks
Signature: RequiredAcks
|
|
timeout
Signature: Timeout
|
|
topics
Signature: ProduceRequestTopicMessageSet []
|
|
transactionalId
Signature: TransactionalId
|
|
Constructors
| Constructor | Description |
new(...)
Signature: (requiredAcks:RequiredAcks * timeout:Timeout * topics:ProduceRequestTopicMessageSet [] * transactionalId:TransactionalId) -> ProduceRequest
|
CompiledName: |
new(requiredAcks, timeout, topics)
Signature: (requiredAcks:RequiredAcks * timeout:Timeout * topics:ProduceRequestTopicMessageSet []) -> ProduceRequest
|
CompiledName: |
