Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package in.springframework.blog.tutorials.configs;
- import in.springframework.blog.tutorials.Constants;
- import org.apache.kafka.clients.producer.ProducerConfig;
- import org.apache.kafka.common.serialization.StringSerializer;
- import org.springframework.beans.factory.annotation.Value;
- import org.springframework.context.annotation.Bean;
- import org.springframework.kafka.core.DefaultKafkaProducerFactory;
- import org.springframework.kafka.core.KafkaTemplate;
- import org.springframework.kafka.core.ProducerFactory;
- import org.springframework.stereotype.Component;
- import java.util.HashMap;
- import java.util.Map;
- @Component
- public class SecondTopicProducerConfig {
- @Value("${spring.kafka.topic2.bootstrap-servers:localhost}")
- private String bootstrapAddress;
- public ProducerFactory<String, String> producerFactory() {
- Map<String, Object> configProps = new HashMap<>();
- configProps.put(
- ProducerConfig.BOOTSTRAP_SERVERS_CONFIG,
- bootstrapAddress);
- configProps.put(
- ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,
- StringSerializer.class);
- configProps.put(
- ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,
- StringSerializer.class);
- return new DefaultKafkaProducerFactory<>(configProps);
- }
- @Bean(name = Constants.SECOND_TOPIC_TEMPLATE_NAME)
- public KafkaTemplate<String, String> kafkaTemplate() {
- return new KafkaTemplate<>(producerFactory());
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement