TransportAutoConfiguration

The node's topic transport: the one a TransportProvider gives, found on the classpath or among the application's beans (PortProviders), configured by its keys (wow.kafka.* for Wow's Kafka transport). The host builds nothing of a broker's own: it takes the transport's ports.

• Transport: the TopicTransport the configured provider opens, closed with the context after the node stopped; its TopicProducer, PartitionedSource and TopicAdmin as beans, unless the application has its own.

• Sink: PublishedSinks.topics over the producer, one subscription per stream the Manifest publishes, each written to its topic after the transport's topics.prefix (wow.kafka.topics.prefix).

• Source: the SourceTopics over the source, the producer and the admin, after the same prefix, with the transport's command-intake.enabled, ddl and topics.partition-refresh (TopicTransportOptions, which every topic transport has): the subscriptions of other contexts' streams read through it, and a saga's commands to other contexts go through it.

• Warnings: once the application is ready, what the transport warns about the node's command topics (TopicTransport.warnings), such as one that does not survive the loss of a broker.

• Offset gaps: the transport is opened with the node's observers (TransportConfig.observer), which it tells of every read that started past its partition's retention; wow-observability counts them.