org.springframework.kafka |
Base package for kafka
|
org.springframework.kafka.annotation |
Package for kafka annotations
|
org.springframework.kafka.config |
Package for kafka configuration
|
org.springframework.kafka.core |
Package for kafka core components
|
org.springframework.kafka.core.reactive |
Reactive component for consumer and producer.
|
org.springframework.kafka.event |
Application Events.
|
org.springframework.kafka.jdocs.dynamic |
|
org.springframework.kafka.jdocs.requestreply |
|
org.springframework.kafka.jdocs.started.consumer |
|
org.springframework.kafka.jdocs.started.noboot |
|
org.springframework.kafka.jdocs.started.producer |
|
org.springframework.kafka.jdocs.topics |
|
org.springframework.kafka.listener |
Package for kafka listeners
|
org.springframework.kafka.listener.adapter |
Provides classes for adapting listeners.
|
org.springframework.kafka.requestreply |
Provides classes for request/reply semantics.
|
org.springframework.kafka.retrytopic |
Package for retryable topic handling.
|
org.springframework.kafka.security.jaas |
Provides classes related to jaas.
|
org.springframework.kafka.streams |
Package for classes related to Kafka Streams.
|
org.springframework.kafka.streams.messaging |
Package for classes related to spring-messaging with Kafka Streams.
|
org.springframework.kafka.support |
Package for kafka support
|
org.springframework.kafka.support.converter |
Package for kafka converters
|
org.springframework.kafka.support.mapping |
Provides classes related to type mapping.
|
org.springframework.kafka.support.micrometer |
Provides classes to support Micrometer.
|
org.springframework.kafka.support.serializer |
|
org.springframework.kafka.test |
|
org.springframework.kafka.test.assertj |
|
org.springframework.kafka.test.condition |
Provides classes for JUnit5 conditions.
|
org.springframework.kafka.test.context |
|
org.springframework.kafka.test.core |
|
org.springframework.kafka.test.hamcrest |
|
org.springframework.kafka.test.rule |
|
org.springframework.kafka.test.utils |
|
org.springframework.kafka.transaction |
Provides classes related to transactions.
|