In this section, we will learn how to configure Producer Compression in KafkaFlow.
KafkaFlow relies on the native message compression provided by the Confluent Kafka client.
Optionally, it's possible to specify the compression level, providing it as the second argument. You can find the possible values here.
services.AddKafka(kafka => kafka
.AddCluster(cluster => cluster
.WithBrokers(new[] { "localhost:9092" })
.AddProducer<ProductEventsProducer>(producer => producer
.WithCompression(CompressionType.Gzip)
...
)
)
)
);
RetroSearch is an open source project built by @garambo | Open a GitHub Issue
Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo
HTML:
3.2
| Encoding:
UTF-8
| Version:
0.7.4