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
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. |
| Key | String |
– | examplekey |
Message key value. Can be empty. |
| Message | String |
– | Example message. |
Message. Can be empty. |
| Partition | Int32 |
0 |
0 |
The partition value. If set to -1. The partition the message is sent to is determined by the partitioner defined using the Options.Partitioner configuration property. |
| CompressionType | CompressionTypes |
None |
CompressionTypes.None |
Compression codec to use for compressing message sets. Possible values:
|
| SecurityProtocol | SecurityProtocols |
Plaintext |
SecurityProtocols.Plaintext |
Protocol used to communicate with brokers. Possible values:
|