Reducing Infrastructure Costs
How to reduce infrastructure costs for WarpStream BYOC clusters.
Last updated
Was this helpful?
.svg?alt=media&token=de534435-d87b-4f47-a762-54ed6aae1b02)
.svg?alt=media&token=5df48930-f99f-4779-b05f-359312e79636)
How to reduce infrastructure costs for WarpStream BYOC clusters.
Last updated
Was this helpful?
WarpStream infrastructure costs can originate from four different sources:
Networking
Storage
Compute
Object Storage API Fees
With WarpStream, you can avoid 100% of inter-AZ networking fees by properly configuring your Kafka clients.
Unlike Apache Kafka, WarpStream Agents will never manually replicate data across availability zones, but Kafka producer/consumer clients can still connect cross-zone, resulting in inter-zone networking fees.
In addition, just like with Apache Kafka, storage costs can be reduced by reducing the retention of your largest topics as well.
The most expensive source of object storage API fees in WarpStream are the PUT requests required to create files as a result of Produce requests. By default, the WarpStream Agents will buffer data in-memory until one of the following two events occur:
The batch timeout elapses
Default value: 250ms
Agent flag: -batchTimeout
Agent environment variable: WARPSTREAM_BATCH_TIMEOUT
A sufficient amount of uncompressed bytes is accumulated
Default value: 4MiB
Agent flag: batchMaxSizeBytes
Agent environment variable: WARPSTREAM_BATCH_MAX_SIZE_BYTES
at which point the Agent will flush a file to the object store and then acknowledge the Produce request as a success back to the client.
To determine how much uncompressed data is stored in the files your Agents are creating for Produce requests, check the average value of the metric: warpstream_agent_segment_batcher_flush_file_size_uncompressed_bytes
If this value is close to (or larger than) the value of batchMaxSizeBytes, then your PUT request costs can be reduced by increasing the amount uncompressed data that is written to each file, resulting in fewer total files being created. There are two ways to accomplish this:
Increase the value of batchTimeout. For example, if the average uncompressed size of files created by your Agents is 2MiB, then doubling the batch timeout from 250ms to 500ms should double the uncompressed file size to 4MiB and cut the number of PUT requests in half. The downside of this approach though is that it will increase the latency of Produce requests.
Once the average size of your uncompressed files is approaching the value of batchMaxSizeBytes then you can increase the value of batchMaxSizeBytes and repeat the steps above to further reduce PUT request costs.
This happens because by default WarpStream has no way of knowing which availability zone the client is connecting from. To avoid this issue, configure your Kafka clients to announce what availability zone they're running in using a , and WarpStream will take care of zonally aligning your Kafka clients (for both Produce and Fetch requests) resulting in almost zero inter-zone networking fees.
WarpStream uses object storage as the primary and only storage in the system. As a result, storage costs in WarpStream tend to be in WarpStream than they are in Apache Kafka. Storage costs can be reduced even further by configuring the WarpStream Agents to store data compressed using ZSTD instead of LZ4. Check out our for more details.
The easiest way to reduce WarpStream Agent compute costs is to auto-scale the Agents based on CPU usage. This feature is built-in to our .
WarpStream's entire is designed around minimizing object storage API fees as much as possible. This is accomplished with a file format that can store data for many different topic-partitions, as well as heavy usage of buffering, batching, and caching in the Agents.
Reduce the number of Agents that are handling Produce requests. This can be accomplished by running a smaller number of Agents, but using larger instance types. Alternatively, you can use the feature to split Producer / Consumer Agents.
