micord/ervu-lkrp-ul
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

SUPPORT-8556: Fix

Browse source
This commit is contained in:
Eduard Tihomirov 2024-09-27 09:45:12 +03:00
parent c9d7135af8
commit ea48e67cb9
1 changed files with 13 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

20
backend/src/main/java/ervu/AvKafkaConfig.java
View file

@ -7,6 +7,7 @@ import org.apache.kafka.clients.CommonClientConfigs;
import org.apache.kafka.clients.producer.ProducerConfig;
import org.apache.kafka.common.config.SaslConfigs;
import org.apache.kafka.common.serialization.StringSerializer;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@ -34,12 +35,14 @@ public class AvKafkaConfig {
@Value("${av.kafka.sasl.mechanism}")
private String saslMechanism;
@Bean("av-factory")
@Bean()
@Qualifier("avProducerFactory")
public ProducerFactory<String, String> producerFactory() {
return new DefaultKafkaProducerFactory<>(producerConfigs());
}
@Bean("av-configs")
@Bean()
@Qualifier("avProducerConfigs")
public Map<String, Object> producerConfigs() {
Map<String, Object> props = new HashMap<>();
props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, this.kafkaUrl);
@ -54,13 +57,15 @@ public class AvKafkaConfig {
return props;
}
@Bean("av-cons-factory")
@Bean()
@Qualifier("avConsumerFactory")
public ConsumerFactory<String, String> consumerFactory() {
return new DefaultKafkaConsumerFactory<>(consumerConfig());
return new DefaultKafkaConsumerFactory<>(consumerConfigs());
}
@Bean("av-cons-configs")
public Map<String, Object> consumerConfig() {
@Bean()
@Qualifier("avConsumerConfigs")
public Map<String, Object> consumerConfigs() {
Map<String, Object> props = new HashMap<>();
props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, this.kafkaUrl);
props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
@ -74,7 +79,8 @@ public class AvKafkaConfig {
return props;
}
@Bean("av-template")
@Bean()
@Qualifier("avTemplate")
public KafkaTemplate<String, String> kafkaTemplate() {
return new KafkaTemplate<>(producerFactory());
}