fix report tests
This commit is contained in:
parent
df63b37e3c
commit
e220d147bb
1 changed files with 5 additions and 5 deletions
|
|
@ -20,9 +20,9 @@ public class KafkaConfig {
|
|||
return KafkaConsumerFactory.consumer(settings.getKafkaConsumer());
|
||||
}
|
||||
|
||||
// @Autowired
|
||||
// @Bean
|
||||
// public Producer<String, Object> createProducer(ReportsServiceSettings settings) {
|
||||
// return KafkaProducerFactory.producer(settings.getKafkaProducer());
|
||||
// }
|
||||
@Autowired
|
||||
@Bean
|
||||
public Producer<String, Object> createProducer(ReportsServiceSettings settings) {
|
||||
return KafkaProducerFactory.producer(settings.getKafkaProducer());
|
||||
}
|
||||
}
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue