Apache Iggy
Server

Topic Options

Retention, durability, and segment layout are per-topic decisions, made when the topic is created. They used to be server-wide [system.*] keys, which gave every knob two homes. The server now refuses to boot on the old keys, and each topic carries its own values instead.

Options are key-value pairs sent with CreateTopic. Unknown keys are rejected at the edge, never skipped: a silently ignored knob would leave the client on server defaults with no way to find out. The same mechanism exists for streams and users, but their catalogs are empty today. Only topics have option keys.

The catalog

OptionDefaultConstraintsDescription
max_topic_sizeunlimitedDelete the oldest sealed segments once the topic grows past this size.
message_expirynoneDelete sealed segments older than this.
compression_algorithmnonenone or gzipPlaceholder: stored and reported, no compression applied yet.
segment_size1 GiB512-byte multiple, at least 1 MiB, at most 1 GiBSoft size limit per segment: a segment may close one whole batch past it.
enforce_fsyncfalsefsync every write to this topic's partitions.
messages_required_to_save1024non-zero, at most 16777216Flush the journal once it holds this many messages.
size_of_messages_required_to_save1 MiBat most 1 GiBFlush the journal once it holds this many bytes. Paired with the message count; whichever threshold trips first flushes.
preallocate_segmentsfalsesegment_size x partitions at most 64 GiB per createReserve each segment's bytes up front where the filesystem supports it.

Both retention policies can be active at once. The active segment is never touched. Deletion is done by the server's segment cleaner ([data_maintenance.messages], enabled by default).

Value forms are forgiving: byte sizes accept a raw number of bytes or a string like "128 MiB", expiry accepts microseconds or a humantime string like "7 days", booleans accept true/false. Create admission re-parses and re-encodes what you send, so a string segment_size=128MiB is stored as the number it names.

preallocate_segments reserves exactly segment_size of real disk per partition the moment the topic is created (and again as segments rotate). With the default 1 GiB segment size that's 1 GiB per partition up front, which is why it's opt-in and why one create is capped at 64 GiB of total reservation.

Setting options

At creation, every interface takes the same keys:

# CLI: --set is repeatable. Positional arguments: stream, name,
# partitions count, compression algorithm.
iggy topic create my-stream my-topic 1 none \
  --set segment_size=128MiB \
  --set enforce_fsync=true

In the CLI, compression_algorithm, message_expiry, and max_topic_size also have first-class parameters on iggy topic create. --set covers the storage knobs that have no named parameter of their own. Values are sent as strings and parsed server-side, so iggy options topic (below) tells you exactly what this server accepts.

SDKs pass options as a parameter on the create call (TopicCreateOptions::raw in Rust, an options dictionary or list in Node, Python, Go, Java, C#, and C++). The HTTP API takes them as a plain string map in the create body.

Keys you don't send are resolved to the defaults above by the admitting server and stored as derived entries. GetTopic returns both blocks, explicit and derived, so the effective value of every knob is always visible, along with who chose it.

Create-only vs updatable

Only three options can change after creation, via UpdateTopic:

  • compression_algorithm
  • message_expiry
  • max_topic_size

Updates are patches: a key you don't send keeps its current value.

The storage knobs (segment_size, enforce_fsync, messages_required_to_save, size_of_messages_required_to_save, preallocate_segments) are create-only. They describe how a partition's storage is laid down: changing segment_size mid-segment would leave segments sized by different caps, and preallocation can only act on a file not yet opened. A topic gets them at creation and keeps them, so its segments stay uniform. This is also why the server refuses to boot on the old config keys instead of ignoring them: a topic created while an old key was silently dropped could never be given the setting afterwards.

Discovering the catalog

Ask the server which keys it accepts, with their types, defaults, and descriptions:

# CLI
iggy options topic

# HTTP
GET /options/topic

SDKs expose the same call as describe_options. The scope is topic, stream, or user.

Discovery matters most on the binary transports: TCP, QUIC, and WebSocket carry only an error code for a rejected key, not its name, so the catalog is how a client finds out what this server supports. Over HTTP the error message names the offending key directly.

Durability

Single-node durability is a per-topic decision. For the strongest guarantee, create the topic with enforce_fsync=true. Every write is then fsynced before it is acknowledged. Without it, the flush thresholds (messages_required_to_save, size_of_messages_required_to_save) bound how much buffered data a crash can lose, at much higher throughput.

In cluster mode, durability comes from quorum replication: a write is acknowledged once a majority of replicas hold it. See Clustering.

On this page