Rename packages for code samples to match sections

See gh-27132
pull/28078/head
Madhura Bhave 3 years ago
parent ad8cb539ea
commit 7e257dc24c

@ -1,3 +1,4 @@
[[actuator]] [[actuator]]
= Production-ready Features = Production-ready Features
include::attributes.adoc[] include::attributes.adoc[]

@ -38,7 +38,7 @@ The following listing shows an example of such a bean:
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/nosql/redis/connecting/MyBean.java[] include::{docs-java}/data/nosql/redis/connecting/MyBean.java[]
---- ----
TIP: You can also register an arbitrary number of beans that implement `LettuceClientConfigurationBuilderCustomizer` for more advanced customizations. TIP: You can also register an arbitrary number of beans that implement `LettuceClientConfigurationBuilderCustomizer` for more advanced customizations.
@ -66,7 +66,7 @@ The following example shows how to connect to a MongoDB database:
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/nosql/mongodb/connecting/MyBean.java[] include::{docs-java}/data/nosql/mongodb/connecting/MyBean.java[]
---- ----
If you have defined your own `MongoClient`, it will be used to auto-configure a suitable `MongoDatabaseFactory`. If you have defined your own `MongoClient`, it will be used to auto-configure a suitable `MongoDatabaseFactory`.
@ -120,7 +120,7 @@ As with `JdbcTemplate`, Spring Boot auto-configures a bean for you to inject the
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/nosql/mongodb/template/MyBean.java[] include::{docs-java}/data/nosql/mongodb/template/MyBean.java[]
---- ----
See the {spring-data-mongodb-api}/core/MongoOperations.html[`MongoOperations` Javadoc] for complete details. See the {spring-data-mongodb-api}/core/MongoOperations.html[`MongoOperations` Javadoc] for complete details.
@ -137,7 +137,7 @@ You could take the JPA example from earlier and, assuming that `City` is now a M
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/nosql/mongodb/repositories/CityRepository.java[] include::{docs-java}/data/nosql/mongodb/repositories/CityRepository.java[]
---- ----
TIP: You can customize document scanning locations by using the `@EntityScan` annotation. TIP: You can customize document scanning locations by using the `@EntityScan` annotation.
@ -182,7 +182,7 @@ The following example shows how to inject a Neo4j `Driver` that gives you access
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/nosql/neo4j/connecting/MyBean.java[] include::{docs-java}/data/nosql/neo4j/connecting/MyBean.java[]
---- ----
You can configure various aspects of the driver using `spring.neo4j.*` properties. You can configure various aspects of the driver using `spring.neo4j.*` properties.
@ -214,7 +214,7 @@ You could take the JPA example from earlier and define `City` as Spring Data Neo
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/nosql/neo4j/repositories/CityRepository.java[] include::{docs-java}/data/nosql/neo4j/repositories/CityRepository.java[]
---- ----
The `spring-boot-starter-data-neo4j` "`Starter`" enables the repository support as well as transaction management. The `spring-boot-starter-data-neo4j` "`Starter`" enables the repository support as well as transaction management.
@ -230,7 +230,7 @@ To enable transaction management, the following bean must be defined in your con
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/nosql/neo4j/repositories/MyNeo4jConfiguration.java[] include::{docs-java}/data/nosql/neo4j/repositories/MyNeo4jConfiguration.java[]
---- ----
==== ====
@ -251,7 +251,7 @@ The following example shows how to inject a Solr bean:
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/nosql/solr/connecting/MyBean.java[] include::{docs-java}/data/nosql/solr/connecting/MyBean.java[]
---- ----
If you add your own `@Bean` of type `SolrClient`, it replaces the default. If you add your own `@Bean` of type `SolrClient`, it replaces the default.
@ -343,7 +343,7 @@ as shown in the following example:
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/nosql/elasticsearch/connectingusingspringdata/MyBean.java[] include::{docs-java}/data/nosql/elasticsearch/connectingusingspringdata/MyBean.java[]
---- ----
In the presence of `spring-data-elasticsearch` and the required dependencies for using a `WebClient` (typically `spring-boot-starter-webflux`), Spring Boot can also auto-configure a <<features#data.nosql.elasticsearch.connecting-using-rest.webclient,ReactiveElasticsearchClient>> and a `ReactiveElasticsearchTemplate` as beans. In the presence of `spring-data-elasticsearch` and the required dependencies for using a `WebClient` (typically `spring-boot-starter-webflux`), Spring Boot can also auto-configure a <<features#data.nosql.elasticsearch.connecting-using-rest.webclient,ReactiveElasticsearchClient>> and a `ReactiveElasticsearchTemplate` as beans.
@ -436,7 +436,7 @@ The following code listing shows how to inject a Cassandra bean:
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/nosql/cassandra/connecting/MyBean.java[] include::{docs-java}/data/nosql/cassandra/connecting/MyBean.java[]
---- ----
If you add your own `@Bean` of type `CassandraTemplate`, it replaces the default. If you add your own `@Bean` of type `CassandraTemplate`, it replaces the default.
@ -515,7 +515,7 @@ The following examples shows how to inject a `CouchbaseTemplate` bean:
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/nosql/couchbase/repositories/MyBean.java[] include::{docs-java}/data/nosql/couchbase/repositories/MyBean.java[]
---- ----
There are a few beans that you can define in your own configuration to override those provided by the auto-configuration: There are a few beans that you can define in your own configuration to override those provided by the auto-configuration:
@ -529,7 +529,7 @@ For instance, you can customize the converters to use, as follows:
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/nosql/couchbase/repositories/MyCouchbaseConfiguration.java[] include::{docs-java}/data/nosql/couchbase/repositories/MyCouchbaseConfiguration.java[]
---- ----
@ -576,7 +576,7 @@ You can also inject an auto-configured `LdapTemplate` instance as you would with
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/nosql/ldap/repositories/MyBean.java[] include::{docs-java}/data/nosql/ldap/repositories/MyBean.java[]
---- ----

@ -160,7 +160,7 @@ Spring's `JdbcTemplate` and `NamedParameterJdbcTemplate` classes are auto-config
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/sql/jdbctemplate/MyBean.java[] include::{docs-java}/data/sql/jdbctemplate/MyBean.java[]
---- ----
You can customize some properties of the template by using the `spring.jdbc.template.*` properties, as shown in the following example: You can customize some properties of the template by using the `spring.jdbc.template.*` properties, as shown in the following example:
@ -204,7 +204,7 @@ A typical entity class resembles the following example:
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/sql/jpaandspringdata/entityclasses/City.java[] include::{docs-java}/data/sql/jpaandspringdata/entityclasses/City.java[]
---- ----
TIP: You can customize entity scanning locations by using the `@EntityScan` annotation. TIP: You can customize entity scanning locations by using the `@EntityScan` annotation.
@ -227,7 +227,7 @@ The following example shows a typical Spring Data repository interface definitio
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/sql/jpaandspringdata/repositories/CityRepository.java[] include::{docs-java}/data/sql/jpaandspringdata/repositories/CityRepository.java[]
---- ----
Spring Data JPA repositories support three different modes of bootstrapping: default, deferred, and lazy. Spring Data JPA repositories support three different modes of bootstrapping: default, deferred, and lazy.
@ -255,7 +255,7 @@ To use Spring Data Envers, make sure your repository extends from `RevisionRepos
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/sql/jpaandspringdata/repositories/CountryRepository.java[] include::{docs-java}/data/sql/jpaandspringdata/repositories/CountryRepository.java[]
---- ----
NOTE: For more details, check the {spring-data-envers-doc}[Spring Data Envers reference documentation]. NOTE: For more details, check the {spring-data-envers-doc}[Spring Data Envers reference documentation].
@ -389,7 +389,7 @@ To use the `DSLContext`, you can inject it, as shown in the following example:
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/sql/jooq/dslcontext/MyBean.java[tag=!method] include::{docs-java}/data/sql/jooq/dslcontext/MyBean.java[tag=!method]
---- ----
TIP: The jOOQ manual tends to use a variable named `create` to hold the `DSLContext`. TIP: The jOOQ manual tends to use a variable named `create` to hold the `DSLContext`.
@ -398,7 +398,7 @@ You can then use the `DSLContext` to construct your queries, as shown in the fol
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/sql/jooq/dslcontext/MyBean.java[tag=method] include::{docs-java}/data/sql/jooq/dslcontext/MyBean.java[tag=method]
---- ----
@ -451,14 +451,14 @@ The following example shows how to manually override the database port while the
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/sql/r2dbc/MyR2dbcConfiguration.java[] include::{docs-java}/data/sql/r2dbc/MyR2dbcConfiguration.java[]
---- ----
The following examples show how to set some PostgreSQL connection options: The following examples show how to set some PostgreSQL connection options:
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/sql/r2dbc/MyPostgresR2dbcConfiguration.java[] include::{docs-java}/data/sql/r2dbc/MyPostgresR2dbcConfiguration.java[]
---- ----
When a `ConnectionFactory` bean is available, the regular JDBC `DataSource` auto-configuration backs off. When a `ConnectionFactory` bean is available, the regular JDBC `DataSource` auto-configuration backs off.
@ -495,7 +495,7 @@ A `DatabaseClient` bean is auto-configured, and you can `@Autowire` it directly
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/sql/r2dbc/usingdatabaseclient/MyBean.java[] include::{docs-java}/data/sql/r2dbc/usingdatabaseclient/MyBean.java[]
---- ----
@ -515,7 +515,7 @@ The following example shows a typical Spring Data repository interface definitio
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/sql/r2dbc/repositories/CityRepository.java[] include::{docs-java}/data/sql/r2dbc/repositories/CityRepository.java[]
---- ----
TIP: We have barely scratched the surface of Spring Data R2DBC. For complete details, see the {spring-data-r2dbc-docs}[Spring Data R2DBC reference documentation]. TIP: We have barely scratched the surface of Spring Data R2DBC. For complete details, see the {spring-data-r2dbc-docs}[Spring Data R2DBC reference documentation].

@ -11,7 +11,7 @@ In a nutshell, to add caching to an operation of your service add the relevant a
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/caching/MyMathService.java[] include::{docs-java}/io/caching/MyMathService.java[]
---- ----
This example demonstrates the use of caching on a potentially costly operation. This example demonstrates the use of caching on a potentially costly operation.
@ -61,7 +61,7 @@ The following example sets a flag to say that `null` values should be passed dow
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/caching/provider/MyCacheManagerConfiguration.java[] include::{docs-java}/io/caching/provider/MyCacheManagerConfiguration.java[]
---- ----
NOTE: In the preceding example, an auto-configured `ConcurrentMapCacheManager` is expected. NOTE: In the preceding example, an auto-configured `ConcurrentMapCacheManager` is expected.
@ -177,7 +177,7 @@ The following example shows a customizer that configures a specific entry expira
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/caching/provider/couchbase/MyCouchbaseCacheManagerConfiguration.java[] include::{docs-java}/io/caching/provider/couchbase/MyCouchbaseCacheManagerConfiguration.java[]
---- ----
@ -208,7 +208,7 @@ The following example shows a customizer that configures a specific time to live
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/caching/provider/redis/MyRedisCacheManagerConfiguration.java[] include::{docs-java}/io/caching/provider/redis/MyRedisCacheManagerConfiguration.java[]
---- ----

@ -43,7 +43,7 @@ You can inject into your bean without needing to use any `@Qualifier`:
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/jta/mixingxaandnonxaconnections/primary/MyBean.java[tag=*] include::{docs-java}/io/jta/mixingxaandnonxaconnections/primary/MyBean.java[tag=*]
---- ----
In some situations, you might want to process certain JMS messages by using a non-XA `ConnectionFactory`. In some situations, you might want to process certain JMS messages by using a non-XA `ConnectionFactory`.
@ -53,14 +53,14 @@ If you want to use a non-XA `ConnectionFactory`, you can the `nonXaJmsConnection
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/jta/mixingxaandnonxaconnections/nonxa/MyBean.java[tag=*] include::{docs-java}/io/jta/mixingxaandnonxaconnections/nonxa/MyBean.java[tag=*]
---- ----
For consistency, the `jmsConnectionFactory` bean is also provided by using the bean alias `xaJmsConnectionFactory`: For consistency, the `jmsConnectionFactory` bean is also provided by using the bean alias `xaJmsConnectionFactory`:
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/jta/mixingxaandnonxaconnections/xa/MyBean.java[tag=*] include::{docs-java}/io/jta/mixingxaandnonxaconnections/xa/MyBean.java[tag=*]
---- ----

@ -52,5 +52,5 @@ Regular beans can also be injected in a similar manner, as shown in the followin
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/quartz/MySampleJob.java[] include::{docs-java}/io/quartz/MySampleJob.java[]
---- ----

@ -13,7 +13,7 @@ The following code shows a typical example:
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/resttemplate/MyService.java[] include::{docs-java}/io/restclient/resttemplate/MyService.java[]
---- ----
TIP: `RestTemplateBuilder` includes a number of useful methods that can be used to quickly configure a `RestTemplate`. TIP: `RestTemplateBuilder` includes a number of useful methods that can be used to quickly configure a `RestTemplate`.
@ -35,7 +35,7 @@ The following example shows a customizer that configures the use of a proxy for
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/resttemplate/customization/MyRestTemplateCustomizer.java[] include::{docs-java}/io/restclient/resttemplate/customization/MyRestTemplateCustomizer.java[]
---- ----
Finally, you can also create your own `RestTemplateBuilder` bean. Finally, you can also create your own `RestTemplateBuilder` bean.
@ -44,7 +44,7 @@ The following example exposes a `RestTemplateBuilder` with what Spring Boot woul
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/resttemplate/customization/MyRestTemplateBuilderConfiguration.java[] include::{docs-java}/io/restclient/resttemplate/customization/MyRestTemplateBuilderConfiguration.java[]
---- ----
The most extreme (and rarely used) option is to create your own `RestTemplateBuilder` bean without using a configurer. The most extreme (and rarely used) option is to create your own `RestTemplateBuilder` bean without using a configurer.
@ -65,7 +65,7 @@ The following code shows a typical example:
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/webclient/MyService.java[] include::{docs-java}/io/restclient/webclient/MyService.java[]
---- ----

@ -8,7 +8,7 @@ For instance, the following service triggers the validation of the first argumen
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/validation/MyBean.java[] include::{docs-java}/io/validation/MyBean.java[]
---- ----
The application's `MessageSource` is used when resolving +`{parameters}`+ in constraint messages. The application's `MessageSource` is used when resolving +`{parameters}`+ in constraint messages.

@ -27,7 +27,7 @@ The following code shows a typical example:
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/webservices/template/MyService.java[] include::{docs-java}/io/webservices/template/MyService.java[]
---- ----
By default, `WebServiceTemplateBuilder` detects a suitable HTTP-based `WebServiceMessageSender` using the available HTTP client libraries on the classpath. By default, `WebServiceTemplateBuilder` detects a suitable HTTP-based `WebServiceMessageSender` using the available HTTP client libraries on the classpath.
@ -35,5 +35,5 @@ You can also customize read and connection timeouts as follows:
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/webservices/template/MyWebServiceTemplateConfiguration.java[] include::{docs-java}/io/webservices/template/MyWebServiceTemplateConfiguration.java[]
---- ----

@ -51,7 +51,7 @@ Spring's `AmqpTemplate` and `AmqpAdmin` are auto-configured, and you can autowir
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/messaging/amqp/sending/MyBean.java[] include::{docs-java}/messaging/amqp/sending/MyBean.java[]
---- ----
NOTE: {spring-amqp-api}/rabbit/core/RabbitMessagingTemplate.html[`RabbitMessagingTemplate`] can be injected in a similar manner. NOTE: {spring-amqp-api}/rabbit/core/RabbitMessagingTemplate.html[`RabbitMessagingTemplate`] can be injected in a similar manner.
@ -88,7 +88,7 @@ The following sample component creates a listener endpoint on the `someQueue` qu
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/messaging/amqp/receiving/MyBean.java[] include::{docs-java}/messaging/amqp/receiving/MyBean.java[]
---- ----
TIP: See {spring-amqp-api}/rabbit/annotation/EnableRabbit.html[the Javadoc of `@EnableRabbit`] for more details. TIP: See {spring-amqp-api}/rabbit/annotation/EnableRabbit.html[the Javadoc of `@EnableRabbit`] for more details.
@ -102,14 +102,14 @@ For instance, the following configuration class exposes another factory that use
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/messaging/amqp/receiving/custom/MyRabbitConfiguration.java[] include::{docs-java}/messaging/amqp/receiving/custom/MyRabbitConfiguration.java[]
---- ----
Then you can use the factory in any `@RabbitListener`-annotated method, as follows: Then you can use the factory in any `@RabbitListener`-annotated method, as follows:
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/messaging/amqp/receiving/custom/MyBean.java[] include::{docs-java}/messaging/amqp/receiving/custom/MyBean.java[]
---- ----
You can enable retries to handle situations where your listener throws an exception. You can enable retries to handle situations where your listener throws an exception.

@ -128,7 +128,7 @@ Spring's `JmsTemplate` is auto-configured, and you can autowire it directly into
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/messaging/jms/sending/MyBean.java[] include::{docs-java}/messaging/jms/sending/MyBean.java[]
---- ----
NOTE: {spring-framework-api}/jms/core/JmsMessagingTemplate.html[`JmsMessagingTemplate`] can be injected in a similar manner. NOTE: {spring-framework-api}/jms/core/JmsMessagingTemplate.html[`JmsMessagingTemplate`] can be injected in a similar manner.
@ -153,7 +153,7 @@ The following component creates a listener endpoint on the `someQueue` destinati
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/messaging/jms/receiving/MyBean.java[] include::{docs-java}/messaging/jms/receiving/MyBean.java[]
---- ----
TIP: See {spring-framework-api}/jms/annotation/EnableJms.html[the Javadoc of `@EnableJms`] for more details. TIP: See {spring-framework-api}/jms/annotation/EnableJms.html[the Javadoc of `@EnableJms`] for more details.
@ -164,12 +164,12 @@ For instance, the following example exposes another factory that uses a specific
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/messaging/jms/receiving/custom/MyJmsConfiguration.java[] include::{docs-java}/messaging/jms/receiving/custom/MyJmsConfiguration.java[]
---- ----
Then you can use the factory in any `@JmsListener`-annotated method as follows: Then you can use the factory in any `@JmsListener`-annotated method as follows:
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/messaging/jms/receiving/custom/MyBean.java[] include::{docs-java}/messaging/jms/receiving/custom/MyBean.java[]
---- ----

@ -27,7 +27,7 @@ Spring's `KafkaTemplate` is auto-configured, and you can autowire it directly in
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/messaging/kafka/sending/MyBean.java[] include::{docs-java}/messaging/kafka/sending/MyBean.java[]
---- ----
NOTE: If the property configprop:spring.kafka.producer.transaction-id-prefix[] is defined, a `KafkaTransactionManager` is automatically configured. NOTE: If the property configprop:spring.kafka.producer.transaction-id-prefix[] is defined, a `KafkaTransactionManager` is automatically configured.
@ -44,7 +44,7 @@ The following component creates a listener endpoint on the `someTopic` topic:
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/messaging/kafka/receiving/MyBean.java[] include::{docs-java}/messaging/kafka/receiving/MyBean.java[]
---- ----
If a `KafkaTransactionManager` bean is defined, it is automatically associated to the container factory. If a `KafkaTransactionManager` bean is defined, it is automatically associated to the container factory.
@ -73,7 +73,7 @@ To use the factory bean, wire `StreamsBuilder` into your `@Bean` as shown in the
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/messaging/kafka/streams/MyKafkaStreamsConfiguration.java[] include::{docs-java}/messaging/kafka/streams/MyKafkaStreamsConfiguration.java[]
---- ----
By default, the streams managed by the `StreamBuilder` object it creates are started automatically. By default, the streams managed by the `StreamBuilder` object it creates are started automatically.
@ -158,14 +158,14 @@ There are several ways to do that:
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/messaging/kafka/embedded/property/MyTest.java[tag=*] include::{docs-java}/messaging/kafka/embedded/property/MyTest.java[tag=*]
---- ----
* Configure a property name on the `@EmbeddedKafka` annotation: * Configure a property name on the `@EmbeddedKafka` annotation:
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/messaging/kafka/embedded/annotation/MyTest.java[] include::{docs-java}/messaging/kafka/embedded/annotation/MyTest.java[]
---- ----
* Use a placeholder in configuration properties: * Use a placeholder in configuration properties:

@ -82,5 +82,5 @@ The following code shows a typical example:
[source,java,indent=0,subs="verbatim"] [source,java,indent=0,subs="verbatim"]
---- ----
include::{docs-java}/features/rsocket//requester/MyService.java[] include::{docs-java}/messaging/rsocket/requester/MyService.java[]
---- ----

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.nosql.cassandra.connecting; package org.springframework.boot.docs.data.nosql.cassandra.connecting;
import org.springframework.data.cassandra.core.CassandraTemplate; import org.springframework.data.cassandra.core.CassandraTemplate;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.nosql.ldap.repositories; package org.springframework.boot.docs.data.nosql.cassandra.connecting;
class User { class User {

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.nosql.couchbase.repositories; package org.springframework.boot.docs.data.nosql.couchbase.repositories;
class CouchbaseProperties { class CouchbaseProperties {

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.nosql.couchbase.repositories; package org.springframework.boot.docs.data.nosql.couchbase.repositories;
import org.springframework.data.couchbase.core.CouchbaseTemplate; import org.springframework.data.couchbase.core.CouchbaseTemplate;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.nosql.couchbase.repositories; package org.springframework.boot.docs.data.nosql.couchbase.repositories;
import org.springframework.core.convert.converter.Converter; import org.springframework.core.convert.converter.Converter;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.nosql.couchbase.repositories; package org.springframework.boot.docs.data.nosql.couchbase.repositories;
import org.assertj.core.util.Arrays; import org.assertj.core.util.Arrays;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.nosql.elasticsearch.connectingusingspringdata; package org.springframework.boot.docs.data.nosql.elasticsearch.connectingusingspringdata;
import org.springframework.data.elasticsearch.core.ElasticsearchRestTemplate; import org.springframework.data.elasticsearch.core.ElasticsearchRestTemplate;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.nosql.elasticsearch.connectingusingspringdata; package org.springframework.boot.docs.data.nosql.elasticsearch.connectingusingspringdata;
class User { class User {

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.nosql.ldap.repositories; package org.springframework.boot.docs.data.nosql.ldap.repositories;
import java.util.List; import java.util.List;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.nosql.cassandra.connecting; package org.springframework.boot.docs.data.nosql.ldap.repositories;
class User { class User {

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.nosql.mongodb.connecting; package org.springframework.boot.docs.data.nosql.mongodb.connecting;
import com.mongodb.client.MongoCollection; import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase; import com.mongodb.client.MongoDatabase;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.sql.r2dbc.repositories; package org.springframework.boot.docs.data.nosql.mongodb.repositories;
public class City { public class City {

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.nosql.mongodb.repositories; package org.springframework.boot.docs.data.nosql.mongodb.repositories;
import org.springframework.data.domain.Page; import org.springframework.data.domain.Page;
import org.springframework.data.domain.Pageable; import org.springframework.data.domain.Pageable;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.nosql.mongodb.template; package org.springframework.boot.docs.data.nosql.mongodb.template;
import com.mongodb.client.MongoCollection; import com.mongodb.client.MongoCollection;
import org.bson.Document; import org.bson.Document;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.nosql.neo4j.connecting; package org.springframework.boot.docs.data.nosql.neo4j.connecting;
import org.neo4j.driver.Driver; import org.neo4j.driver.Driver;
import org.neo4j.driver.Session; import org.neo4j.driver.Session;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.nosql.neo4j.repositories; package org.springframework.boot.docs.data.nosql.neo4j.repositories;
public class City { public class City {

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.nosql.neo4j.repositories; package org.springframework.boot.docs.data.nosql.neo4j.repositories;
import java.util.Optional; import java.util.Optional;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.nosql.neo4j.repositories; package org.springframework.boot.docs.data.nosql.neo4j.repositories;
import org.neo4j.driver.Driver; import org.neo4j.driver.Driver;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.nosql.redis.connecting; package org.springframework.boot.docs.data.nosql.redis.connecting;
import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.nosql.solr.connecting; package org.springframework.boot.docs.data.nosql.solr.connecting;
import java.io.IOException; import java.io.IOException;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.sql.jdbctemplate; package org.springframework.boot.docs.data.sql.jdbctemplate;
import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.sql.jooq.dslcontext; package org.springframework.boot.docs.data.sql.jooq.dslcontext;
import java.util.GregorianCalendar; import java.util.GregorianCalendar;
import java.util.List; import java.util.List;
@ -23,7 +23,7 @@ import org.jooq.DSLContext;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import static org.springframework.boot.docs.features.sql.jooq.dslcontext.Tables.AUTHOR; import static org.springframework.boot.docs.data.sql.jooq.dslcontext.Tables.AUTHOR;
@Component @Component
public class MyBean { public class MyBean {

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.sql.jooq.dslcontext; package org.springframework.boot.docs.data.sql.jooq.dslcontext;
import java.util.GregorianCalendar; import java.util.GregorianCalendar;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.sql.jpaandspringdata.entityclasses; package org.springframework.boot.docs.data.sql.jpaandspringdata.entityclasses;
import java.io.Serializable; import java.io.Serializable;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.sql.jpaandspringdata.entityclasses; package org.springframework.boot.docs.data.sql.jpaandspringdata.entityclasses;
import java.io.Serializable; import java.io.Serializable;

@ -14,9 +14,9 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.sql.jpaandspringdata.repositories; package org.springframework.boot.docs.data.sql.jpaandspringdata.repositories;
import org.springframework.boot.docs.features.sql.jpaandspringdata.entityclasses.City; import org.springframework.boot.docs.data.sql.jpaandspringdata.entityclasses.City;
import org.springframework.data.domain.Page; import org.springframework.data.domain.Page;
import org.springframework.data.domain.Pageable; import org.springframework.data.domain.Pageable;
import org.springframework.data.repository.Repository; import org.springframework.data.repository.Repository;

@ -14,9 +14,9 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.sql.jpaandspringdata.repositories; package org.springframework.boot.docs.data.sql.jpaandspringdata.repositories;
import org.springframework.boot.docs.features.sql.jpaandspringdata.entityclasses.Country; import org.springframework.boot.docs.data.sql.jpaandspringdata.entityclasses.Country;
import org.springframework.data.domain.Page; import org.springframework.data.domain.Page;
import org.springframework.data.domain.Pageable; import org.springframework.data.domain.Pageable;
import org.springframework.data.repository.Repository; import org.springframework.data.repository.Repository;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.sql.r2dbc; package org.springframework.boot.docs.data.sql.r2dbc;
import java.util.HashMap; import java.util.HashMap;
import java.util.Map; import java.util.Map;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.sql.r2dbc; package org.springframework.boot.docs.data.sql.r2dbc;
import io.r2dbc.spi.ConnectionFactoryOptions; import io.r2dbc.spi.ConnectionFactoryOptions;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.nosql.mongodb.repositories; package org.springframework.boot.docs.data.sql.r2dbc.repositories;
public class City { public class City {

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.sql.r2dbc.repositories; package org.springframework.boot.docs.data.sql.r2dbc.repositories;
import reactor.core.publisher.Mono; import reactor.core.publisher.Mono;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.sql.r2dbc.usingdatabaseclient; package org.springframework.boot.docs.data.sql.r2dbc.usingdatabaseclient;
import java.util.Map; import java.util.Map;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.caching; package org.springframework.boot.docs.io.caching;
import org.springframework.cache.annotation.Cacheable; import org.springframework.cache.annotation.Cacheable;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.caching.provider; package org.springframework.boot.docs.io.caching.provider;
import org.springframework.boot.autoconfigure.cache.CacheManagerCustomizer; import org.springframework.boot.autoconfigure.cache.CacheManagerCustomizer;
import org.springframework.cache.concurrent.ConcurrentMapCacheManager; import org.springframework.cache.concurrent.ConcurrentMapCacheManager;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.caching.provider.couchbase; package org.springframework.boot.docs.io.caching.provider.couchbase;
import java.time.Duration; import java.time.Duration;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.caching.provider.redis; package org.springframework.boot.docs.io.caching.provider.redis;
import java.time.Duration; import java.time.Duration;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.jta.mixingxaandnonxaconnections.nonxa; package org.springframework.boot.docs.io.jta.mixingxaandnonxaconnections.nonxa;
import javax.jms.ConnectionFactory; import javax.jms.ConnectionFactory;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.jta.mixingxaandnonxaconnections.primary; package org.springframework.boot.docs.io.jta.mixingxaandnonxaconnections.primary;
import javax.jms.ConnectionFactory; import javax.jms.ConnectionFactory;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.jta.mixingxaandnonxaconnections.xa; package org.springframework.boot.docs.io.jta.mixingxaandnonxaconnections.xa;
import javax.jms.ConnectionFactory; import javax.jms.ConnectionFactory;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.quartz; package org.springframework.boot.docs.io.quartz;
import org.quartz.JobExecutionContext; import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException; import org.quartz.JobExecutionException;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.quartz; package org.springframework.boot.docs.io.quartz;
import java.util.Date; import java.util.Date;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.resttemplate; package org.springframework.boot.docs.io.restclient.resttemplate;
class Details { class Details {

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.resttemplate; package org.springframework.boot.docs.io.restclient.resttemplate;
import org.springframework.boot.web.client.RestTemplateBuilder; import org.springframework.boot.web.client.RestTemplateBuilder;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.resttemplate.customization; package org.springframework.boot.docs.io.restclient.resttemplate.customization;
import java.time.Duration; import java.time.Duration;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.resttemplate.customization; package org.springframework.boot.docs.io.restclient.resttemplate.customization;
import org.apache.http.HttpException; import org.apache.http.HttpException;
import org.apache.http.HttpHost; import org.apache.http.HttpHost;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.webclient; package org.springframework.boot.docs.io.restclient.webclient;
import org.neo4j.cypherdsl.core.Relationship.Details; import org.neo4j.cypherdsl.core.Relationship.Details;
import reactor.core.publisher.Mono; import reactor.core.publisher.Mono;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.validation; package org.springframework.boot.docs.io.validation;
class Archive { class Archive {

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.validation; package org.springframework.boot.docs.io.validation;
class Author { class Author {

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.validation; package org.springframework.boot.docs.io.validation;
import javax.validation.constraints.Size; import javax.validation.constraints.Size;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.webservices.template; package org.springframework.boot.docs.io.webservices.template;
import org.springframework.boot.webservices.client.WebServiceTemplateBuilder; import org.springframework.boot.webservices.client.WebServiceTemplateBuilder;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.webservices.template; package org.springframework.boot.docs.io.webservices.template;
import java.time.Duration; import java.time.Duration;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.webservices.template; package org.springframework.boot.docs.io.webservices.template;
class SomeRequest { class SomeRequest {

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.webservices.template; package org.springframework.boot.docs.io.webservices.template;
class SomeResponse { class SomeResponse {

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.messaging.amqp.receiving; package org.springframework.boot.docs.messaging.amqp.receiving;
import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.messaging.amqp.receiving.custom; package org.springframework.boot.docs.messaging.amqp.receiving.custom;
import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.messaging.amqp.receiving.custom; package org.springframework.boot.docs.messaging.amqp.receiving.custom;
import org.springframework.amqp.core.Message; import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessageProperties; import org.springframework.amqp.core.MessageProperties;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.messaging.amqp.receiving.custom; package org.springframework.boot.docs.messaging.amqp.receiving.custom;
import org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory; import org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory;
import org.springframework.amqp.rabbit.connection.ConnectionFactory; import org.springframework.amqp.rabbit.connection.ConnectionFactory;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.messaging.amqp.sending; package org.springframework.boot.docs.messaging.amqp.sending;
import org.springframework.amqp.core.AmqpAdmin; import org.springframework.amqp.core.AmqpAdmin;
import org.springframework.amqp.core.AmqpTemplate; import org.springframework.amqp.core.AmqpTemplate;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.messaging.jms.receiving; package org.springframework.boot.docs.messaging.jms.receiving;
import org.springframework.jms.annotation.JmsListener; import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.messaging.jms.receiving.custom; package org.springframework.boot.docs.messaging.jms.receiving.custom;
import org.springframework.jms.annotation.JmsListener; import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.messaging.jms.receiving.custom; package org.springframework.boot.docs.messaging.jms.receiving.custom;
import javax.jms.ConnectionFactory; import javax.jms.ConnectionFactory;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.messaging.jms.receiving.custom; package org.springframework.boot.docs.messaging.jms.receiving.custom;
import javax.jms.JMSException; import javax.jms.JMSException;
import javax.jms.Message; import javax.jms.Message;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.messaging.jms.sending; package org.springframework.boot.docs.messaging.jms.sending;
import org.springframework.jms.core.JmsTemplate; import org.springframework.jms.core.JmsTemplate;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.messaging.kafka.embedded.annotation; package org.springframework.boot.docs.messaging.kafka.embedded.annotation;
import org.springframework.boot.test.context.SpringBootTest; import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.kafka.test.context.EmbeddedKafka; import org.springframework.kafka.test.context.EmbeddedKafka;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.messaging.kafka.embedded.property; package org.springframework.boot.docs.messaging.kafka.embedded.property;
import org.springframework.boot.test.context.SpringBootTest; import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.kafka.test.EmbeddedKafkaBroker; import org.springframework.kafka.test.EmbeddedKafkaBroker;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.messaging.kafka.receiving; package org.springframework.boot.docs.messaging.kafka.receiving;
import org.springframework.kafka.annotation.KafkaListener; import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.messaging.kafka.sending; package org.springframework.boot.docs.messaging.kafka.sending;
import org.springframework.kafka.core.KafkaTemplate; import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.messaging.kafka.streams; package org.springframework.boot.docs.messaging.kafka.streams;
import org.apache.kafka.common.serialization.Serdes; import org.apache.kafka.common.serialization.Serdes;
import org.apache.kafka.streams.KeyValue; import org.apache.kafka.streams.KeyValue;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.rsocket.requester; package org.springframework.boot.docs.messaging.rsocket.requester;
import reactor.core.publisher.Mono; import reactor.core.publisher.Mono;

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.boot.docs.features.rsocket.requester; package org.springframework.boot.docs.messaging.rsocket.requester;
class User { class User {
Loading…
Cancel
Save