We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 775428b commit 59afa75Copy full SHA for 59afa75
src/reference/asciidoc/kafka.adoc
@@ -133,7 +133,7 @@ private KafkaAdmin admin;
133
134
...
135
136
- AdminClient client = AdminClient.create(admin.getConfig());
+ AdminClient client = AdminClient.create(admin.getConfigurationProperties());
137
138
client.close();
139
----
@@ -549,7 +549,7 @@ public class KRequestingApplication {
549
@Bean
550
public ReplyingKafkaTemplate<String, String, String> replyingTemplate(
551
ProducerFactory<String, String> pf,
552
- ConcurrentMessageListenerContainer<Long, String> repliesContainer) {
+ ConcurrentMessageListenerContainer<String, String> repliesContainer) {
553
554
return new ReplyingKafkaTemplate<>(pf, repliesContainer);
555
}
0 commit comments