Skip to content

Commit

Permalink
Remove duplicate producerProperties declaration in kafkaProducerFacto…
Browse files Browse the repository at this point in the history
…ry (#3605)
  • Loading branch information
JiwonKKang authored Oct 29, 2024
1 parent 4ccc63c commit de5383f
Showing 1 changed file with 1 addition and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -30,11 +30,9 @@ public class Application {
Map<String, Object> producerProperties = new HashMap<>();
// producerProperties.put(..., ...)
// ...
Map<String, Object> producerProperties = properties.buildProducerProperties();
producerProperties.put(ProducerConfig.INTERCEPTOR_CLASSES_CONFIG, MyProducerInterceptor.class.getName());
producerProperties.put("some.bean", someBean);
DefaultKafkaProducerFactory<?, ?> factory = new DefaultKafkaProducerFactory<>(producerProperties);
return factory;
return new DefaultKafkaProducerFactory<>(producerProperties);
}
@Bean
Expand Down

0 comments on commit de5383f

Please sign in to comment.