BatchingExtensions class
no needed
public static class BatchingExtensions
Public Members
name | description |
---|---|
static AddBatching(…) | Accumulates a group of messages to be passed as a batch to the next middleware as just one message |
static GetMessagesBatch(…) | Gets the accumulated IMessageContext grouped by batching middleware |
See Also
- namespace KafkaFlow