KafkaTransportProvider

The Kafka transport, type kafka: available once bootstrap-servers is set. Its settings, relative to its configuration (wow.kafka.*), are its options:

• bootstrap-servers, properties.* (passed to every client as they are) and poll-timeout, with the topic transports' topics.partition-refresh as the clients' metadata age: KafkaOptions;

• offset-gap: what a read does with an offset its partition no longer holds (OffsetGapPolicy, fail by default);

• topics.replication-factor, topics.min-insync-replicas and topics.configs.*: what the topics it creates get.

The producer is idempotent with acks=all; the source reads with no consumer group (KafkaPartitionedSource). TopicTransport.warnings warns about a configuration that creates topics losing commands with one broker, and about each of the node's command topics that does not survive the loss of a broker, unless the node runs for development (TransportConfig.development).