All Implemented Interfaces:


public final class StreamConfig

DSL for configuring JetStream streams

Example usage:

val streamCtx = js.stream("MY_STREAM") {
    subjects = listOf("orders.*", "payments.*")
    retentionPolicy = RetentionPolicy.LIMITS
    maxMessages = 1000000
    maxBytes = 1024 * 1024 * 1024 // 1GB
    storageType = StorageType.FILE
    replicas = 3
}

Nested Class Summary

Nested Classes
Modifier and Type	Class	Description

Field Summary

Fields
Modifier and Type	Field	Description
`private final List<String>`	`subjects`
`private final RetentionPolicy`	`retentionPolicy`
`private final Integer`	`maxConsumers`
`private final Long`	`maxMessages`
`private final Long`	`maxBytes`
`private final Duration`	`maxAge`
`private final Integer`	`maxMsgSize`
`private final StorageType`	`storageType`
`private final Integer`	`replicas`
`private final Boolean`	`noAck`
`private final Duration`	`duplicateWindow`
`private final DiscardPolicy`	`discardPolicy`
`private final String`	`description`
`private final Placement`	`placement`
`private final StreamSource`	`mirror`
`private final List<StreamSource>`	`sources`
`private final Long`	`maxMessagesPerSubject`

Constructor Summary

Constructors
Constructor	Description

Enum Constant Summary

Enum Constants
Enum Constant	Description

Method Summary

Modifier and Type	Method	Description
`final List<String>`	`getSubjects()`	List of subjects this stream listens to Supports wildcards (e.g., "orders.*", "payments.>")
`final RetentionPolicy`	`getRetentionPolicy()`	Retention policy for the stream
`final Integer`	`getMaxConsumers()`	Maximum number of consumers allowed on this stream (-1 for unlimited)
`final Long`	`getMaxMessages()`	Maximum number of messages to retain (-1 for unlimited)
`final Long`	`getMaxBytes()`	Maximum total bytes to retain (-1 for unlimited)
`final Duration`	`getMaxAge()`	Maximum age of messages to retain (Duration.
`final Integer`	`getMaxMsgSize()`	Maximum size of a single message (-1 for unlimited)
`final StorageType`	`getStorageType()`	Storage type for the stream
`final Integer`	`getReplicas()`	Number of replicas for the stream (1-5)
`final Boolean`	`getNoAck()`	Disable acknowledgments (used for fire-and-forget scenarios)
`final Duration`	`getDuplicateWindow()`	Window within which to track duplicate messages
`final DiscardPolicy`	`getDiscardPolicy()`	Discard policy when limits are reached
`final String`	`getDescription()`	Description of the stream
`final Placement`	`getPlacement()`	Placement configuration for clustering
`final StreamSource`	`getMirror()`	Mirror configuration to mirror another stream
`final List<StreamSource>`	`getSources()`	List of sources to aggregate from multiple streams
`final Long`	`getMaxMessagesPerSubject()`	Maximum messages per subject (-1 for unlimited)

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
- Method Detail
  - getSubjects
```
 final List<String> getSubjects()
```
    List of subjects this stream listens to Supports wildcards (e.g., "orders.*", "payments.>")
  - getRetentionPolicy
```
 final RetentionPolicy getRetentionPolicy()
```
    Retention policy for the stream
  - getMaxConsumers
```
 final Integer getMaxConsumers()
```
    Maximum number of consumers allowed on this stream (-1 for unlimited)
  - getMaxMessages
```
 final Long getMaxMessages()
```
    Maximum number of messages to retain (-1 for unlimited)
  - getMaxBytes
```
 final Long getMaxBytes()
```
    Maximum total bytes to retain (-1 for unlimited)
  - getMaxAge
```
 final Duration getMaxAge()
```
    Maximum age of messages to retain (Duration.ZERO for unlimited)
  - getMaxMsgSize
```
 final Integer getMaxMsgSize()
```
    Maximum size of a single message (-1 for unlimited)
  - getStorageType
```
 final StorageType getStorageType()
```
    Storage type for the stream
  - getReplicas
```
 final Integer getReplicas()
```
    Number of replicas for the stream (1-5)
  - getNoAck
```
 final Boolean getNoAck()
```
    Disable acknowledgments (used for fire-and-forget scenarios)
  - getDuplicateWindow
```
 final Duration getDuplicateWindow()
```
    Window within which to track duplicate messages
  - getDiscardPolicy
```
 final DiscardPolicy getDiscardPolicy()
```
    Discard policy when limits are reached
  - getDescription
```
 final String getDescription()
```
    Description of the stream
  - getPlacement
```
 final Placement getPlacement()
```
    Placement configuration for clustering
  - getMirror
```
 final StreamSource getMirror()
```
    Mirror configuration to mirror another stream
  - getSources
```
 final List<StreamSource> getSources()
```
    List of sources to aggregate from multiple streams
  - getMaxMessagesPerSubject
```
 final Long getMaxMessagesPerSubject()
```
    Maximum messages per subject (-1 for unlimited)

Class StreamConfig

Nested Class Summary

Field Summary

Constructor Summary

Enum Constant Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

Method Detail

getSubjects

getRetentionPolicy

getMaxConsumers

getMaxMessages

getMaxBytes

getMaxAge

getMaxMsgSize

getStorageType

getReplicas

getNoAck

getDuplicateWindow

getDiscardPolicy

getDescription

getPlacement

getMirror

getSources

getMaxMessagesPerSubject