Frends.Kafka.Consume / 3.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
3.0.02026-10-27
Changed
- Task now targets .NET 8.
- Breaking Socket, SASL, SSL and Schema Registry parameters are now grouped under a single Connection parameter.
- Result now contains an Error property describing the failure when the Task does not throw.
- Added Options.ThrowErrorOnFailure and Options.ErrorMessageOnFailure to control error handling.
2.0.02024-05-15
Added
- Support for Confluent Schema Registry based Avro.
- New parameter Options.Debug.
Changed
- Confluent.Kafka updated from version 1.9.3 to 2.4.
- Input.Partition change: Consume from all topic's partitions if set to -1.
- New parameter: Options.EncodeMessageKey to choose whether this Task will try to encode consumed key to string from byte[]
- Message class change: string Key, string Value replaced by dynamic Key, dynamic Value.
- Result.Messages renamed to Result.Data.
- Removed optional parameters: ApiVersionRequest, ApiVersionFallbackMs, ApiVersionRequestTimeoutMs, AllowAutoCreateTopics,
1.1.02023-11-27
Added
- Added a partition as input parameter to the task.
1.0.12023-04-17
Fixed
- Changed Task to set ssl.SslCaCertificateStores only if it's set as parameter.
1.0.02022-10-19
Added
- Initial implementation