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 4ccc63c commit de5383fCopy full SHA for de5383f
spring-kafka-docs/src/main/antora/modules/ROOT/pages/kafka/interceptors.adoc
@@ -30,11 +30,9 @@ public class Application {
30
Map<String, Object> producerProperties = new HashMap<>();
31
// producerProperties.put(..., ...)
32
// ...
33
- Map<String, Object> producerProperties = properties.buildProducerProperties();
34
producerProperties.put(ProducerConfig.INTERCEPTOR_CLASSES_CONFIG, MyProducerInterceptor.class.getName());
35
producerProperties.put("some.bean", someBean);
36
- DefaultKafkaProducerFactory<?, ?> factory = new DefaultKafkaProducerFactory<>(producerProperties);
37
- return factory;
+ return new DefaultKafkaProducerFactory<>(producerProperties);
38
}
39
40
@Bean
0 commit comments