Frends.Kafka.Produce / 3.0.0
Summary
Publishes a message to a topic with an optional key, which is what decides partitioning and therefore per-key ordering.
Typical use — emitting events from a Process; keying by entity is what keeps that entity's events in order
3.0.02026-10-27
Changed
- Breaking Socket, Sasl, Ssl and SchemaRegistry parameters are now properties of the new Connection parameter. The Task now has the parameters Input, Connection and Options.
- Task now targets .NET 8.
Added
- Options.ThrowErrorOnFailure and Options.ErrorMessageOnFailure for controlling error handling. When ThrowErrorOnFailure is false, failures are returned in Result.Error.
- Result.Error property containing the error message and additional information.
Fixed
- Added missing documentation example for Options.MessageSendMaxRetries.
2.1.02026-07-15
Fixed
- Ssl.SslCaCertificateStores is no longer set when the parameter is empty, so SSL connections work on Linux agents. The property is Windows-only in librdkafka.
2.0.02024-05-14
Added
- Support for Confluent Schema Registry based Avro.
- New parameter Options.Debug.
Changed
- Result.Status and Result.Timestamp have been replaced by Result.Data.
- Changed how partitions are handled when producing message. See Input.Partition description.
- All but Kerberos SASL settings can be used on Windows platform.
- Confluent.Kafka updated from version 1.9.3 to 2.4.
- Parameter removed: Options.ApiVersionRequest.
1.2.02023-10-11
Changed
- Input.Message will no longer be serialized into JSON text before sending.
1.1.02023-09-01
Added
- Input.Partition, set the partition.
- Input.Key, set message key.
1.0.12023-04-04
Fixed
- Changed Task to set ssl.SslCaCertificateStores only if it's set as parameter.
1.0.02022-10-19
Added
- Initial implementation