Frends.Kafka.Consume / 2.0.0
Summary
Reads a bounded number of messages from a topic within a timeout, optionally from one partition, so a run ends whether or not messages arrived.
Typical use — scheduled consumption of a Kafka topic, with the message count as the run's unit of work
Input parameters.
| Name | Type | Default | Example | Description |
|---|---|---|---|---|
| Host | String |
– | localhost:1234 |
Initial list of brokers as a CSV list of broker host or host:port. |
| Topic | String |
– | ExampleTopic |
Topic. |
| SecurityProtocol | SecurityProtocols |
Plaintext |
SecurityProtocols.Plaintext |
Protocol used to communicate with brokers. Possible values:
|
| MessageCount | Int32 |
– | 10 |
Amount of consumed messages before ending this task. 0 = unlimited, consume until timeout or task cancellation. |
| Timeout | Int32 |
0 |
60000 |
Consume operation timeout (value in ms). 0=unlimited. See other timeout options in Options-tab. |
| Partition | Int32 |
– | 10 |
Set Kafka partition. Consume from all topic's partitions if set to -1. |