import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.kafka.annotation.EnableKafka;
+import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.kafka.core.ProducerFactory;
import java.util.Properties;
public RestGateway restGateway(
ApplicationProperties applicationProperties,
KafkaProperties kafkaProperties,
- Producer<String, Integer> kafkaProducer)
+ KafkaTemplate<String, Integer> kafkaTemplate)
{
return
new RestGateway(
kafkaProperties.getClientId(),
- applicationProperties.getTopic(),
applicationProperties.getPartition(),
- kafkaProducer);
+ kafkaTemplate);
}
@Bean(destroyMethod = "close")