Class KafkaStreams

java.lang.Object
io.micronaut.starter.feature.testresources.EaseTestingFeature
io.micronaut.starter.feature.messaging.kafka.KafkaStreams
All Implemented Interfaces:
io.micronaut.core.naming.Described, io.micronaut.core.naming.Named, io.micronaut.core.order.Ordered, Feature, OpenRewriteFeature, MessagingFeature, SharedTestResourceFeature

@Requires(property="micronaut.starter.feature.kafka.streams.enabled", value="true", defaultValue="true") @Singleton public class KafkaStreams extends EaseTestingFeature implements MessagingFeature, SharedTestResourceFeature, OpenRewriteFeature
Kafka Streams messaging feature.

Adds support for Kafka Streams and ensures Kafka feature is included if not already selected. Provides example listener and factory templates in multiple languages.