Skip to content

Commit e398d34

Browse files
garyrussellartembilan
authored andcommitted
SI Outbound result channel docs
Since we added gateways, a dedicated success channel is now provided instead of using the output channel for result metadata.
1 parent 95ebeb6 commit e398d34

File tree

1 file changed

+3
-4
lines changed

1 file changed

+3
-4
lines changed

src/reference/asciidoc/si-kafka.adoc

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -94,6 +94,7 @@ public MessageHandler handler() throws Exception {
9494
new KafkaProducerMessageHandler<>(kafkaTemplate());
9595
handler.setTopicExpression(new LiteralExpression("someTopic"));
9696
handler.setMessageKeyExpression(new LiteralExpression("someKey"));
97+
handler.setSuccessChannel(successes());
9798
handler.setFailureChannel(failures());
9899
return handler;
99100
}
@@ -156,13 +157,11 @@ private KafkaProducerMessageHandlerSpec<Integer, String, ?> kafkaMessageHandler(
156157
}
157158
----
158159

159-
If a `send-failure-channel` is provided, if a send failure is received (sync or async), an `ErrorMessage` is sent to the channel.
160+
If a `send-failure-channel` (`sendFailureChannel`) is provided, if a send failure is received (sync or async), an `ErrorMessage` is sent to the channel.
160161
The payload is a `KafkaSendFailureException` with properties `failedMessage`, `record` (the `ProducerRecord`) and `cause`.
161162
The `DefaultErrorMessageStrategy` can be overridden via the `error-message-strategy` property.
162163

163-
If a `send-success-channel` is provided, a message with a payload of type `org.apache.kafka.clients.producer.RecordMetadata` will be sent after a successful send.
164-
When using Java configuration, use `setOutputChannel` for this purpose.
165-
164+
If a `send-success-channel` (`sendSuccessChannel`) is provided, a message with a payload of type `org.apache.kafka.clients.producer.RecordMetadata` will be sent after a successful send.
166165

167166
[[si-inbound]]
168167
==== Message Driven Channel Adapter

0 commit comments

Comments
 (0)