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 1241e9b commit fddbafeCopy full SHA for fddbafe
spring-kafka/src/main/java/org/springframework/kafka/core/KafkaTemplate.java
@@ -158,6 +158,15 @@ public boolean isTransactional() {
158
return this.transactional;
159
}
160
161
+ /**
162
+ * Return the producer factory used by this template.
163
+ * @return the factory.
164
+ * @since 2.2.5
165
+ */
166
+ public ProducerFactory<K, V> getProducerFactory() {
167
+ return this.producerFactory;
168
+ }
169
+
170
@Override
171
public ListenableFuture<SendResult<K, V>> sendDefault(@Nullable V data) {
172
return send(this.defaultTopic, data);
0 commit comments