InMemoryTopicsAutoConfiguration

@AutoConfiguration
@EnableConfigurationProperties(value = [WowProperties::class])
class InMemoryTopicsAutoConfiguration(environment: Environment)

The node's topics in its JVM, for trying a service out without Kafka (DX gap G27), when wow.transport selects them (TransportSelection.MEMORY: memory, or auto in development without a configured transport): one InMemoryTopics of wow.log.partitions partitions, each keeping its last wow.memory.topic-retention messages, unless the application has one of its own, as wow-kafka's beans give them on Kafka:

  • the SourceTopics with the producer and the intake, so each context the node hosts executes its command topic, whose topics the node creates at its start (Ddl.AUTO);

  • the PublishedSinks of the streams the Manifest publishes.

It warns at startup that nothing leaves the JVM. wow.transport=memory outside development is refused.

Constructors

Link copied to clipboard
constructor(environment: Environment)

Types

Link copied to clipboard

Functions

Link copied to clipboard
@Bean(value = ["wowInMemorySinks"])
fun wowInMemorySinks(manifest: Manifest, topics: InMemoryTopics): PublishedSinks
Link copied to clipboard
@Bean
@ConditionalOnMissingBean
fun wowInMemorySourceTopics(topics: InMemoryTopics): SourceTopics
Link copied to clipboard
@Bean
@ConditionalOnMissingBean
fun wowInMemoryTopics(properties: WowProperties): InMemoryTopics
Link copied to clipboard
@Bean
fun wowInMemoryTopicsWarning(): ApplicationListener<ApplicationReadyEvent>

Warns, once the application is ready, that the node's topics are in its JVM.