diff --git a/docs/src/main/asciidoc/overview.adoc b/docs/src/main/asciidoc/overview.adoc index 9306bce11..140905477 100644 --- a/docs/src/main/asciidoc/overview.adoc +++ b/docs/src/main/asciidoc/overview.adoc @@ -512,7 +512,7 @@ public class Application { Enable transactions by setting `spring.cloud.stream.kafka.binder.transaction.transactionIdPrefix` to a non-empty value, e.g. `tx-`. When used in a processor application, the consumer starts the transaction; any records sent on the consumer thread participate in the same transaction. When the listener exits normally, the listener container will send the offset to the transaction and commit it. -A common producer factory is used for all producer bindings configure using `spring.cloud.stream.kafka.binder.transaction.producer.*` properties; individual binding Kafka producer properties are ignored. +A common producer factory is used for all producer bindings configured using `spring.cloud.stream.kafka.binder.transaction.producer.*` properties; individual binding Kafka producer properties are ignored. If you wish to use transactions in a source application, or from some arbitrary thread for producer-only transaction (e.g. `@Scheduled` method), you must get a reference to the transactional producer factory and define a `KafkaTransactionManager` bean using it. @@ -532,7 +532,7 @@ Notice that we get a reference to the binder using the `BinderFactory`; use `nul If more than one binder is configured, use the binder name to get the reference. Once we have a reference to the binder, we can obtain a reference to the `ProducerFactory` and create a transaction manager. -Then you would just normal Spring transaction support, e.g. `TransactionTemplate` or `@Transactional`, for example: +Then you would use normal Spring transaction support, e.g. `TransactionTemplate` or `@Transactional`, for example: ==== [source, java]