package de.juplo.kafka.payment.transfer;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import de.juplo.kafka.payment.transfer.impl.TransferServiceImpl;
import lombok.extern.slf4j.Slf4j;
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerConfig;
return new KafkaProducer<>(props);
}
+ @Bean
+ TransferServiceImpl transferService(
+ KafkaProducer<UUID, String> producer,
+ ObjectMapper mapper,
+ TransferServiceProperties properties)
+ {
+ return new TransferServiceImpl(producer, mapper, properties.topic);
+ }
+
+
public static void main(String[] args)
{
SpringApplication.run(TransferServiceApplication.class, args);