From 6976bcd3a89a7707cdc8d536b3badae36cb11af4 Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Tue, 9 Jul 2019 14:36:14 -0400 Subject: [PATCH] Docs polishing --- docs/src/main/asciidoc/overview.adoc | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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]