Skip to content

Commit 7ccf9d9

Browse files
garyrussellartembilan
authored andcommitted
GH-1397: Channel doc polishing
1 parent 76dc266 commit 7ccf9d9

File tree

1 file changed

+10
-2
lines changed

1 file changed

+10
-2
lines changed

src/reference/asciidoc/si-kafka.adoc

Lines changed: 10 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -648,14 +648,22 @@ public IntegrationFlow flowWithPubSub(KafkaTemplate<Integer, String> template,
648648
649649
return IntegrationFlows.from(...)
650650
...
651-
.publishSubscribeChannel(Kafka.publishSubscribeChannel(
652-
template, containerFactory, "someTopic2").groupId("group2"),
651+
.publishSubscribeChannel(pubSub(template, containerFactory),
653652
pubsub -> pubsub
654653
.subscribe(subflow -> ...)
655654
.subscribe(subflow -> ...))
656655
.get();
657656
}
658657
658+
@Bean
659+
public BroadcastCapableChannel pubSub(KafkaTemplate<Integer, String> template,
660+
ConcurrentKafkaListenerContainerFactory<Integer, String> containerFactory) {
661+
662+
return Kafka.publishSubscribeChannel(template, containerFactory, "someTopic2")
663+
.groupId("group2")
664+
.get();
665+
}
666+
659667
@Bean
660668
public IntegrationFlow flowWithPollable(KafkaTemplate<Integer, String> template,
661669
KafkaMessageSource<Integer, String> source) {

0 commit comments

Comments
 (0)